ハッカソンのAPIをGoへフルスクラッチしました

paths:
  /releases:
    get:
      tags:
        - Releases
      security:
        - bearerAuth: []
      summary: 最新順リリース一覧取得API
      description: 最新順リリース一覧取得API #ToDo: Orderをつけるか？
      parameters:
        - in: query
          name: per_page
          description: The number of results per page (max 999).
          schema:
            type: integer
            example: 30
            default: 100
            maximum: 999
        - in: query
          name: page
          description: Page number of the results to fetch (max 99).
          schema:
            type: integer
            example: 1
            default: 0
            maximum: 99
        - in: query
          name: from_date
          description: 指定期間開始（YYYY-MM-DD、指定なしは本日の日付から1week前）
          schema:
            type: string
            example: '2021-04-01'
            default: '2022-08-01'
        - in: query
          name: to_date
          description: 指定期間終了（YYYY-MM-DD、指定なしは本日の日付）
          schema:
            type: string
            example: '2021-04-02'
            default: '2022-08-08'
      responses:
        200:
          description: OK
          content:
            application/json:
              schema:
                type: array
                items:
                  $ref: '#/components/schemas/press_release'
components:
  securitySchemes:
    bearerAuth:
      type: http
      scheme: bearer
      description: |
        API を利用するにはBearer認証が必要です。
  schemas:
    press_release:
      title: 'プレスリリース情報'
      type: object
      properties:
        company_name:
          type: string
          description: 企業名
          example: '株式会社PR TIMES'
          x-oapi-codegen-extra-tags:
            db: company_name
        company_id:
          type: integer
          description: 企業ID
          example: 1
          x-go-name: CompanyID
          x-oapi-codegen-extra-tags:
            db: company_id
        release_id:
          type: integer
          description: リリースID
          example: 1
          x-go-name: ReleaseID
          x-oapi-codegen-extra-tags:
            db: release_id
        title:
          type: string
          description: タイトル
          example: '[April Dream] 4月1日を夢の日に。1100社超が「夢」の発信に参加表明'
          x-oapi-codegen-extra-tags:
            db: title
      required:
        - company_name
        - company_id
        - release_id
        - title

api:
    # Go実装の場合は golang/ node実装の場合は node/
    build: golang/
    # Go実装の場合は./golang:/app/go/base, node実装の場合は./node/src/.:/src
    volumes:
      # - ./node/src/.:/src
      - ./golang:/app/go/base
      - ./public:/app/go/public
(略)

├── docker-compose.yml
├── golang
│   ├── Dockerfile
│   ├── README.md
│   ├── go.mod
│   ├── go.sum
│   ├── main.go (基本的な処理を書く)
│   └── openapi
│       ├── handlers.go (Interface, routerなどが自動生成される)
│       └── openapi.go (structが自動生成される)
└── public
    ├── spec
	      └── hackathon-api.yaml　（API仕様書を定義する）

(略)
RUN go install github.com/cosmtrek/air@latest

COPY . .

CMD ["air", "-c", "./.air.toml"]

oapi-codegen -generate "types" --old-config-style -package "openapi"  ../public/spec/hackathon-api.yaml > openapi/openapi.go

// Package openapi provides primitives to interact with the openapi HTTP API.
//
// Code generated by github.com/deepmap/oapi-codegen version v1.11.0 DO NOT EDIT.
package openapi

const (
	BearerAuthScopes = "bearerAuth.Scopes"
)

// PressRelease defines model for press_release.
type PressRelease struct {
	// 企業ID
	CompanyID int `db:"company_id" json:"company_id"`

	// 企業名
	CompanyName string `db:"company_name" json:"company_name"`

	// リリースID
	ReleaseID int `db:"release_id" json:"release_id"`

	// タイトル
	Title string `db:"title" json:"title"`
}

// GetReleasesParams defines parameters for GetReleases.
type GetReleasesParams struct {
	// The number of results per page (max 999).
	PerPage *int `form:"per_page,omitempty" json:"per_page,omitempty"`

	// Page number of the results to fetch (max 99).
	Page *int `form:"page,omitempty" json:"page,omitempty"`

	// 指定期間開始（YYYY-MM-DD、指定なしは本日の日付から1week前）
	FromDate *string `form:"from_date,omitempty" json:"from_date,omitempty"`

	// 指定期間終了（YYYY-MM-DD、指定なしは本日の日付）
	ToDate *string `form:"to_date,omitempty" json:"to_date,omitempty"`
}

oapi-codegen -generate "server" --old-config-style -package "openapi" ../public/spec/hackathon-api.yaml > openapi/handlers.go

// Package openapi provides primitives to interact with the openapi HTTP API.
//
// Code generated by github.com/deepmap/oapi-codegen version v1.11.0 DO NOT EDIT.
package openapi

import (
	"fmt"
	"net/http"

	"github.com/deepmap/oapi-codegen/pkg/runtime"
	"github.com/labstack/echo/v4"
)

// ServerInterface represents all server handlers.
type ServerInterface interface {
	// 最新順リリース一覧取得API
	// (GET /releases)
	GetReleases(ctx echo.Context, params GetReleasesParams) error
}

// ServerInterfaceWrapper converts echo contexts to parameters.
type ServerInterfaceWrapper struct {
	Handler ServerInterface
}

// GetReleases converts echo context to params.
func (w *ServerInterfaceWrapper) GetReleases(ctx echo.Context) error {
	var err error

	ctx.Set(BearerAuthScopes, []string{""})

	// Parameter object where we will unmarshal all parameters from the context
	var params GetReleasesParams
	// ------------- Optional query parameter "per_page" -------------

	err = runtime.BindQueryParameter("form", true, false, "per_page", ctx.QueryParams(), ¶ms.PerPage)
	if err != nil {
		return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter per_page: %s", err))
	}

	// ------------- Optional query parameter "page" -------------

	err = runtime.BindQueryParameter("form", true, false, "page", ctx.QueryParams(), ¶ms.Page)
	if err != nil {
		return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter page: %s", err))
	}

	// ------------- Optional query parameter "from_date" -------------

	err = runtime.BindQueryParameter("form", true, false, "from_date", ctx.QueryParams(), ¶ms.FromDate)
	if err != nil {
		return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter from_date: %s", err))
	}

	// ------------- Optional query parameter "to_date" -------------

	err = runtime.BindQueryParameter("form", true, false, "to_date", ctx.QueryParams(), ¶ms.ToDate)
	if err != nil {
		return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter to_date: %s", err))
	}

	// Invoke the callback with all the unmarshalled arguments
	err = w.Handler.GetReleases(ctx, params)
	return err
}

// This is a simple interface which specifies echo.Route addition functions which
// are present on both echo.Echo and echo.Group, since we want to allow using
// either of them for path registration
type EchoRouter interface {
	CONNECT(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
	DELETE(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
	GET(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
	HEAD(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
	OPTIONS(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
	PATCH(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
	POST(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
	PUT(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
	TRACE(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
}

// RegisterHandlers adds each server route to the EchoRouter.
func RegisterHandlers(router EchoRouter, si ServerInterface) {
	RegisterHandlersWithBaseURL(router, si, "")
}

// Registers handlers, and prepends BaseURL to the paths, so that the paths
// can be served under a prefix.
func RegisterHandlersWithBaseURL(router EchoRouter, si ServerInterface, baseURL string) {

	wrapper := ServerInterfaceWrapper{
		Handler: si,
	}

	router.GET(baseURL+"/releases", wrapper.GetReleases)

}

func (Server) GetReleases(ctx echo.Context, params openapi.GetReleasesParams) error {
	txn := nrecho.FromContext(ctx)
	defer txn.End()

	perPage := 100
	if params.PerPage != nil {
		perPage = *params.PerPage
		txn.AddAttribute("per_page", perPage)
	}
	page := 0
	if params.Page != nil {
		page = *params.Page
		txn.AddAttribute("page", page)
	}

	if perPage >= 1000 {
		return ctx.JSON(http.StatusBadRequest, `{"message": "validation error (out of the limit for par_page. limit is 999)"}`)
	}
	if page >= 100 {
		return ctx.JSON(http.StatusBadRequest, `{"message": "validation error (out of the limit for page. limit is 99)"}`)
	}

	now := time.Now()
	toDate := now
	if params.ToDate != nil {
		parsedTime, err := stringToTime(ctx, *params.ToDate)
		if err != nil {
			return ctx.JSON(http.StatusBadRequest, `{"message": "bad request (invalid type for to_date. valid type is YYYY-mm-dd)"}`)
		}
		toDate = parsedTime
		txn.AddAttribute("to_date", toDate)
	}
	// toDateの日付から1週間前
	fromDate := toDate.AddDate(0, 0, -7)
	if params.FromDate != nil {
		parsedTime, err := stringToTime(ctx, *params.FromDate)
		if err != nil {
			return ctx.JSON(http.StatusBadRequest, `{"message": "bad request (invalid type for from_date. valid type is YYYY-mm-dd)"}`)
		}
		fromDate = parsedTime
		txn.AddAttribute("from_date", fromDate)
	}

	var results []openapi.PressRelease
	// SQLは適当です
	query := `
		SELECT
		    company_id,
		    company_name,
		    release_id,
		    title
		FROM
		    release
		WHERE
		    release_date BETWEEN $1 AND $2
		ORDER BY
		    release_date DESC
		LIMIT $3 OFFSET $4
	`

	err := db.Select(&results, query, fromDate, toDate, perPage, page)
	if err != nil {
		ctx.Logger().Errorf("db error: %v", err)
		return ctx.NoContent(http.StatusInternalServerError)
	}

	if len(results) == 0 {
		return ctx.JSON(http.StatusOK, []openapi.PressRelease{})
	}

	return ctx.JSON(http.StatusOK, results)
}

SELECT array_agg(hoge) AS keywords FROM ~~

db error: sql: Scan error on column index 12, name \"keywords\": unsupported Scan, storing driver.Value type []uint8 into type *[]string

keywords:
  description: キーワード
  type: array
  x-go-type: pq.StringArray
  x-go-type-import:
    path: github.com/lib/pq
  x-oapi-codegen-extra-tags:
    db: keywords

Keywords pq.StringArray `db:"keywords" json:"keywords"`

txn := nrecho.FromContext(ctx)

nrtrace := createDataStoreSegment(query, "release", "SELECT", fromDate, toDate, perPage, page)

def test_get_releases():
    url = f'{config.host}{config.basePath}/releases'
    headers = {'Authorization': f'Bearer {config.token}'}

    res = requests.get(url, headers=headers)
    assert res.status_code == 200, res.content

================================================================================== slowest durations ===================================================================================
40.97s call     test_api.py::test_time_releases_from_date
17.28s call     test_api.py::test_get_releases
16.26s call     test_api.py::test_time_releases_page
0.29s call     test_api.py::test_get_companies
(略)

================================================================================== slowest durations ===================================================================================
0.40s call     test_api.py::test_time_releases_from_date
0.10s call     test_api.py::test_get_categories
0.09s call     test_api.py::test_get_companies
(略)

func main() {
	e := echo.New()
	api := e.Group("/api")
	api.Use(middleware.CORS()) // CORSを通すのが先
	api.Use(bearerAuthMiddleware) // Bearer認証が後
}