protohelpers.go

package main

import (
	"net/http"

	tasks "google.golang.org/genproto/googleapis/cloud/tasks/v2beta3"
	rpccode "google.golang.org/genproto/googleapis/rpc/code"
)

func toHTTPMethod(taskMethod tasks.HttpMethod) string {
	switch taskMethod {
	case tasks.HttpMethod_GET:
		return http.MethodGet
	case tasks.HttpMethod_POST:
		return http.MethodPost
	case tasks.HttpMethod_DELETE:
		return http.MethodDelete
	case tasks.HttpMethod_HEAD:
		return http.MethodHead
	case tasks.HttpMethod_OPTIONS:
		return http.MethodOptions
	case tasks.HttpMethod_PATCH:
		return http.MethodPatch
	case tasks.HttpMethod_PUT:
		return http.MethodPut
	default:
		panic("Unsupported http method")
	}
}

func toRPCStatusCode(statusCode int) int32 {
	switch statusCode {
	case 200:
		return int32(rpccode.Code_OK)
	case 400:
		// TODO: or rpccode.Code_FAILED_PRECONDITION
		// TODO: or rpcCode.Code_OUT_OF_RANGE
		return int32(rpccode.Code_INVALID_ARGUMENT)
	case 401:
		return int32(rpccode.Code_UNAUTHENTICATED)
	case 403:
		return int32(rpccode.Code_PERMISSION_DENIED)
	case 404:
		return int32(rpccode.Code_NOT_FOUND)
	case 409:
		// TODO: or rpccde.Code_ABORTED
		return int32(rpccode.Code_ALREADY_EXISTS)
	case 429:
		return int32(rpccode.Code_RESOURCE_EXHAUSTED)
	case 499:
		return int32(rpccode.Code_CANCELLED)
	case 500:
		//TODO: or rpccode.Code_DATA_LOSS
		return int32(rpccode.Code_INTERNAL)
	case 501:
		return int32(rpccode.Code_UNIMPLEMENTED)
	case 503:
		return int32(rpccode.Code_UNAVAILABLE)
	case 504:
		return int32(rpccode.Code_DEADLINE_EXCEEDED)
	default:
		return int32(rpccode.Code_UNKNOWN)
	}
}

func toCodeName(rpcCode int32) string {
	return rpccode.Code_name[rpcCode]
}