[WebApp] Protocal22-API 사용예제 (GoLang)

[WebApp] Protocal22-API 사용예제2

시작하기 전에

이 문서는 Dabory OwnerKey API for WebApp을 사용해 main app과 guest app 개발시 필요한 참고 정보를 안내합니다.

 WebApp 사용예제

2. WebApp 사용 예제

📌 GateToken 발급 스케줄러

package main
func main() {
	// 새로운 고루틴(Goroutine) 실행: 백그라운드에서 주기적으로 실행됨
	go func() {
		for {
			// 1. UpdateGateTokenIfNeeded() 함수 호출 (GateToken 발급 및 업데이트)
			err := controllers_func.UpdateGateTokenIfNeeded()
			
			// 2. 만약 에러가 발생하면 로그를 남김
			if err != nil {
				e.ErrLog("UpdateGateTokenIfNeeded Error", err)
			}

			// 3. 2초 동안 대기 후 반복 (즉, 2초마다 실행됨)
			time.Sleep(2 * time.Second)
		}
	}()

	// 주의: main 함수가 종료되면 고루틴도 종료됨
	select {} // main 함수가 종료되지 않도록 무한 대기
}

📌 "OwnerKey"를 활용한 GateToken, BackUrl 반환

Host의 dabory-app/gate-token-get을 호출 -> Host -> main_api (GateToken) 반환

// GateToken을 요청하는 함수
func UpdateGateTokenIfNeeded() error {
	myOwnerKey := "My_OwnerKey" //OwnerKey (GateToken 발급 주체 선정을 위해 사용)

	// GateToken을 요청 (OwnerKey를 사용하여 요청)
	err := locals.GuestGateTokenGets(myOwnerKey)
	if err != nil {
		fmt.Println("GateToken 요청 실패:", err)
		return err
	}

	return nil
}


type AppApi struct {
	ApiUrl    string
	GateToken string
}

var GAppApis [2]AppApi // GateToken, ApiUrl 저장 장소 

func GuestGateTokenGets(myOnwerKey string) error { 
	appType := 0 //Dbupdate
	// 0:keypair, 1:Dbu  // "SsoConnString" Must be Deprecated

	var err error

	if myOnwerKey != "" { 
		// e.LogStr("lskdjqfals", e.LogFuncName()+"; GuestGateTokenOwner with OwnerKey: "+myOnwerKey)
		_, _, err = GuestGateTokenOwner(appType, "https://host_domain_URL.com", myOnwerKey) // app type -> OwnerCode
      // Host Domain URL, OwnerKey를 매개변수로 던짐
		if err != nil {
			return e.ErrLog(e.FuncRun("23rfsr3qrase", e.CurrFuncName()), err)
		}
	} 

	return nil
}

func GuestGateTokenOwner(appType int, pivotUrl string, ownerKey string) (string, string, error) { // HOST URL/dabory-app ->  pivot URL
	var appTypeCode string
	if appType == 0 {
		appTypeCode = "keypair"
	} else if appType == 1 {
		appTypeCode = "dbupdate"
	}

	if GAppApis[appType].GateToken != "" { // 할당되어 있는 경우 (이미 GateToken이 있는 경우)
		// fmt.Println("34092ujfa : "+"Using GateToken in ARRAY to access : ", GAppApis[0].GateToken)
	} else { // (GateToken이 없는 경우 발급 로직)
		fmt.Println("34092ujfa : " + "isn't exist GateToken in ARRAY to access ")

		vGt := &GateTokenGetReq{
			OwnerKey: ownerKey,
		}
		bodyBytes, _ := json.Marshal(vGt)

		frontUrl := pivotUrl + "/dabory-app/gate-token-get" 
		msgBytes, staInt, err := HttpResponseSimplePost("POST", frontUrl, bodyBytes) 
        // Strong -> Host Lalavel로 Http 요청 -> Lalavel -> main_api로 GateToken 요청
		e.LogStr("23rfsr3qr-GateTokenGetReq", e.LogFuncName()+";  Raravel frontUrl : "+frontUrl)
		if err != nil {
			return "", "", e.ErrLog(e.FuncRun("45425fd34sd-The HTTP request "+frontUrl, e.CurrFuncName()), err)
		}

		if staInt != 200 {
			TrackFailure() // 요청 실패 시 실패 기록 추가
			fmt.Println("GateToken 요청 실패:", err, "(최근 1시간 내 실패 횟수:", len(failTimestamps), ")", "반환 Code : ", staInt)

			// 최근 1시간 동안 실패 횟수가 maxFailures(3) 이상이면 프로그램 종료
			if len(failTimestamps) >= maxFailures {
				fmt.Println("1시간 내 GateToken 요청이", maxFailures, "번 실패 -> 스케줄러를 종료")
				os.Exit(1) // 프로그램 종료
			}

			return "", "", errors.New(e.FuncRun("87ty344ra3-Request Fail "+string(msgBytes), e.CurrFuncName()))
		}

		failTimestamps = []int64{} // 성공 시 실패 기록 초기화

		ret := &struct {
			ApiUrl    string 
			GateToken string
		}{}

		if err := json.Unmarshal(msgBytes, ret); err != nil {  // GateToken과 BackendUrl을 ret 구조체에 할당
			return "", "", e.ErrLog(e.FuncRun("45425fd34sd-Json Format "+frontUrl, e.CurrFuncName()), err)
		}
      // 새로 받은 GateToken을 전역 변수에 저장
		GAppApis[appType].ApiUrl = ret.ApiUrl
		GAppApis[appType].GateToken = ret.GateToken
		e.OkLog("Just Added GateToken in ARRAY to access AppType: " + appTypeCode)
		e.OkLog("Just Added GateToken in ARRAY to access AppType: " + ret.GateToken)
		e.OkLog("Just Added GateToken in ARRAY to access AppType: " + ret.ApiUrl) // main_api URL

	}
	return GAppApis[appType].ApiUrl, GAppApis[appType].GateToken, nil
}

📌 발급받은 GateToken을 사용하여 main_api 요청

// 🔹 API 요청을 수행하는 함수
func process() {
	// 1. GateToken과 API URL 가져오기
	apiUrl := locals.GAppApis[0].ApiUrl    // API 요청을 보낼 기본 URL
	gateToken := locals.GAppApis[0].GateToken // API 요청 시 필요한 인증 토큰

	// 2. 요청할 API 엔드포인트 설정 (credit-page 요청)
	mainApiURL := apiUrl + "/credit-page"

	// 3. 요청 바디 구성 (전달할 데이터)
	requestBody := map[string]interface{}{
		"PageVars": map[string]interface{}{
			"Fields":     "credit_no", 
			"Limit":      1,          
			"Desc":       "id",       
			"MyFilter":   "",         
			"QueryCnt":   0,          
			"Query":      "",         
			"Asc":        "",         
			"Offset":     0,          
			"ReturnJson": "",         
		},
	}

	// 4. API 요청 실행 (GateToken 포함)
	Body, err := RequestWithGateToken(mainApiURL, gateToken, requestBody)
	if err != nil {
		// 요청 실패 시 에러 로그 출력
		e.ErrLog("API 요청 실패: ", err)
		return
	}

	// 5. 응답 데이터 출력
	fmt.Println("API 응답 데이터:", string(Body))
}

📌 저장된 GateToken으로 요청 (만료된 GateToken 재 발급)

// GateToken을 사용하여 API 요청을 보내는 함수
func RequestWithGateToken(mainApiURL string, gateToken string, requestBody map[string]interface{}) ([]byte, error) {
	// 1. HTTP 요청 보내기 (기존 GateToken 사용)
	resp, body, err := SendHttpRequest(mainApiURL, gateToken, requestBody)
	if err != nil {
		fmt.Println("HTTP 요청 실패:", err)
		return nil, err
	}
	defer resp.Body.Close()

	fmt.Println("응답 본문:", string(body)) // API 응답 출력

	// 2. 응답 코드가 505라면 -> GateToken 만료 (새로운 GateToken 발급 필요)
	if resp.StatusCode == 505 {
		fmt.Println("GateToken 만료! 새로운 GateToken 발급 시도..")

		// 기존 만료된 GateToken 초기화
		locals.GAppApis[0] = locals.AppApi{}

		// 스케줄러가 새로운 GateToken이 얻어올 때까지 대기 (최대 5초마다 확인)
		for locals.GAppApis[0].GateToken == "" {
			fmt.Println("새로운 GateToken 발급 중..")
			time.Sleep(5 * time.Second)
		}

		fmt.Println("새로운 GateToken 발급 완료!")

		// 새로운 GateToken으로 API 재요청
		newGateToken := locals.GAppApis[0].GateToken
		resp, body, err := SendHttpRequest(mainApiURL, newGateToken, requestBody)
		if err != nil {
			fmt.Println("HTTP 요청 실패:", err)
			return nil, err
		}
		defer resp.Body.Close()

		// 새로운 요청 응답 확인
		if resp.StatusCode == 200 {
			e.OkLog("새로운 GateToken을 사용한 HTTP 요청 성공!")
			return body, nil
		} else {
			return nil, fmt.Errorf("새로운 GateToken 요청 실패, 상태 코드: %d", resp.StatusCode)
		}
	}

	// 기존 GateToken으로 요청 성공한 경우
	e.OkLog("기존 GateToken을 사용한 HTTP 요청 성공!")
	return body, nil
}

// HTTP 요청을 보내는 함수
func SendHttpRequest(mainApiURL string, gateToken string, requestBody map[string]interface{}) (*http.Response, []byte, error) {
	// 1. JSON 데이터로 변환
	jsonData, err := json.Marshal(requestBody)
	if err != nil {
		fmt.Println("JSON 변환 실패:", err)
		return nil, nil, err
	}

	// 2. HTTP 요청 생성 (POST 요청)
	req, err := http.NewRequest("POST", mainApiURL, bytes.NewBuffer(jsonData))
	if err != nil {
		fmt.Println("HTTP 요청 생성 실패:", err)
		return nil, nil, err
	}

	// 3. HTTP 헤더 설정 (GateToken 포함)
	req.Header.Set("Content-Type", "application/json")
	req.Header.Set("GateToken", gateToken)

	// 4. HTTP 요청 실행
	client := &http.Client{}
	resp, err := client.Do(req)
	if err != nil {
		fmt.Println("HTTP 요청 실패:", err)
		return nil, nil, err
	}

	// 5. 응답 데이터 읽기
	body, err := io.ReadAll(resp.Body)
	if err != nil {
		fmt.Println("응답 본문 읽기 실패:", err)
		return nil, nil, err
	}

	// 6. 응답 로그 출력
	fmt.Println("응답 코드:", resp.StatusCode)
	fmt.Println("응답 본문:", string(body))

	return resp, body, nil
}