Loading...
;
+ if (error) return {error}
;
+
return (
-
+
);
};
-export default App;
\ No newline at end of file
+export default App;
diff --git a/modules/frontend/src/api/core/ApiError.ts b/modules/frontend/src/api/core/ApiError.ts
deleted file mode 100644
index ec7b16a..0000000
--- a/modules/frontend/src/api/core/ApiError.ts
+++ /dev/null
@@ -1,25 +0,0 @@
-/* generated using openapi-typescript-codegen -- do not edit */
-/* istanbul ignore file */
-/* tslint:disable */
-/* eslint-disable */
-import type { ApiRequestOptions } from './ApiRequestOptions';
-import type { ApiResult } from './ApiResult';
-
-export class ApiError extends Error {
- public readonly url: string;
- public readonly status: number;
- public readonly statusText: string;
- public readonly body: any;
- public readonly request: ApiRequestOptions;
-
- constructor(request: ApiRequestOptions, response: ApiResult, message: string) {
- super(message);
-
- this.name = 'ApiError';
- this.url = response.url;
- this.status = response.status;
- this.statusText = response.statusText;
- this.body = response.body;
- this.request = request;
- }
-}
diff --git a/modules/frontend/src/api/core/ApiRequestOptions.ts b/modules/frontend/src/api/core/ApiRequestOptions.ts
deleted file mode 100644
index 93143c3..0000000
--- a/modules/frontend/src/api/core/ApiRequestOptions.ts
+++ /dev/null
@@ -1,17 +0,0 @@
-/* generated using openapi-typescript-codegen -- do not edit */
-/* istanbul ignore file */
-/* tslint:disable */
-/* eslint-disable */
-export type ApiRequestOptions = {
- readonly method: 'GET' | 'PUT' | 'POST' | 'DELETE' | 'OPTIONS' | 'HEAD' | 'PATCH';
- readonly url: string;
- readonly path?: RecordItems List
+ {items.map((item) => ( +Loading...
;
- if (error) return {error}
;
- if (!user) return User not found.
;
-
- return (
-
-
- );
-};
-
-export default UserPage;
diff --git a/modules/sql/go.mod b/modules/sql/go.mod
new file mode 100644
index 0000000..9508b28
--- /dev/null
+++ b/modules/sql/go.mod
@@ -0,0 +1,3 @@
+module tutorial.sqlc.dev/app
+
+go 1.25.2
diff --git a/modules/sql/query.sql b/modules/sql/query.sql
new file mode 100644
index 0000000..4b85e7e
--- /dev/null
+++ b/modules/sql/query.sql
@@ -0,0 +1,142 @@
+-- name: GetImageByID :one
+SELECT image_id, storage_type, image_path
+FROM images
+WHERE image_id = $1;
+
+-- name: CreateImage :one
+INSERT INTO images (storage_type, image_path)
+VALUES ($1, $2)
+RETURNING image_id, storage_type, image_path;
+
+-- name: GetUserByID :one
+SELECT user_id, avatar_id, passhash, mail, nickname, disp_name, user_desc, creation_date
+FROM users
+WHERE user_id = $1;
+
+-- name: ListUsers :many
+SELECT user_id, avatar_id, passhash, mail, nickname, disp_name, user_desc, creation_date
+FROM users
+ORDER BY user_id
+LIMIT $1 OFFSET $2;
+
+-- name: CreateUser :one
+INSERT INTO users (avatar_id, passhash, mail, nickname, disp_name, user_desc, creation_date)
+VALUES ($1, $2, $3, $4, $5, $6, $7)
+RETURNING user_id, avatar_id, nickname, disp_name, user_desc, creation_date;
+
+-- name: UpdateUser :one
+UPDATE users
+SET
+ avatar_id = COALESCE(sqlc.narg('avatar_id'), avatar_id),
+ disp_name = COALESCE(sqlc.narg('disp_name'), disp_name),
+ user_desc = COALESCE(sqlc.narg('user_desc'), user_desc),
+ passhash = COALESCE(sqlc.narg('passhash'), passhash),
+WHERE user_id = sqlc.arg('user_id')
+RETURNING user_id, avatar_id, nickname, disp_name, user_desc, creation_date;
+
+-- name: DeleteUser :exec
+DELETE FROM users
+WHERE user_id = $1;
+
+-- name: GetTitleByID :one
+SELECT title_id, title_names, studio_id, poster_id, signal_ids,
+ title_status, rating, rating_count, release_year, release_season,
+ season, episodes_aired, episodes_all, episodes_len
+FROM titles
+WHERE title_id = $1;
+
+-- name: ListTitles :many
+SELECT title_id, title_names, studio_id, poster_id, signal_ids,
+ title_status, rating, rating_count, release_year, release_season,
+ season, episodes_aired, episodes_all, episodes_len
+FROM titles
+ORDER BY title_id
+LIMIT $1 OFFSET $2;
+
+-- name: UpdateTitle :one
+UPDATE titles
+SET
+ title_names = COALESCE(sqlc.narg('title_names'), title_names),
+ studio_id = COALESCE(sqlc.narg('studio_id'), studio_id),
+ poster_id = COALESCE(sqlc.narg('poster_id'), poster_id),
+ signal_ids = COALESCE(sqlc.narg('signal_ids'), signal_ids),
+ title_status = COALESCE(sqlc.narg('title_status'), title_status),
+ release_year = COALESCE(sqlc.narg('release_year'), release_year),
+ release_season = COALESCE(sqlc.narg('release_season'), release_season),
+ episodes_aired = COALESCE(sqlc.narg('episodes_aired'), episodes_aired),
+ episodes_all = COALESCE(sqlc.narg('episodes_all'), episodes_all),
+ episodes_len = COALESCE(sqlc.narg('episodes_len'), episodes_len)
+WHERE title_id = sqlc.arg('title_id')
+RETURNING *;
+
+-- name: GetReviewByID :one
+SELECT review_id, user_id, title_id, image_ids, review_text, creation_date
+FROM reviews
+WHERE review_id = $1;
+
+-- name: CreateReview :one
+INSERT INTO reviews (user_id, title_id, image_ids, review_text, creation_date)
+VALUES ($1, $2, $3, $4, $5)
+RETURNING review_id, user_id, title_id, image_ids, review_text, creation_date;
+
+-- name: UpdateReview :one
+UPDATE reviews
+SET
+ image_ids = COALESCE(sqlc.narg('image_ids'), image_ids),
+ review_text = COALESCE(sqlc.narg('review_text'), review_text)
+WHERE review_id = sqlc.arg('review_id')
+RETURNING *;
+
+-- name: DeleteReview :exec
+DELETE FROM reviews
+WHERE review_id = $1;
+
+-- name: ListReviewsByTitle :many
+SELECT review_id, user_id, title_id, image_ids, review_text, creation_date
+FROM reviews
+WHERE title_id = $1
+ORDER BY creation_date DESC
+LIMIT $2 OFFSET $3;
+
+-- name: ListReviewsByUser :many
+SELECT review_id, user_id, title_id, image_ids, review_text, creation_date
+FROM reviews
+WHERE user_id = $1
+ORDER BY creation_date DESC
+LIMIT $2 OFFSET $3;
+
+-- name: GetUserTitle :one
+SELECT usertitle_id, user_id, title_id, status, rate, review_id
+FROM usertitles
+WHERE user_id = $1 AND title_id = $2;
+
+-- name: ListUserTitles :many
+SELECT usertitle_id, user_id, title_id, status, rate, review_id
+FROM usertitles
+WHERE user_id = $1
+ORDER BY usertitle_id
+LIMIT $2 OFFSET $3;
+
+-- name: CreateUserTitle :one
+INSERT INTO usertitles (user_id, title_id, status, rate, review_id)
+VALUES ($1, $2, $3, $4, $5)
+RETURNING usertitle_id, user_id, title_id, status, rate, review_id;
+
+-- name: UpdateUserTitle :one
+UPDATE usertitles
+SET
+ status = COALESCE(sqlc.narg('status'), status),
+ rate = COALESCE(sqlc.narg('rate'), rate),
+ review_id = COALESCE(sqlc.narg('review_id'), review_id)
+WHERE user_id = $1 AND title_id = $2
+RETURNING *;
+
+-- name: DeleteUserTitle :exec
+DELETE FROM usertitles
+WHERE user_id = $1 AND ($2::int IS NULL OR title_id = $2);
+
+-- name: ListTags :many
+SELECT tag_id, tag_names
+FROM tags
+ORDER BY tag_id
+LIMIT $1 OFFSET $2;
\ No newline at end of file
diff --git a/modules/sql/scheme.sql b/modules/sql/scheme.sql
new file mode 100644
index 0000000..df84550
--- /dev/null
+++ b/modules/sql/scheme.sql
@@ -0,0 +1,97 @@
+-- TODO:
+-- title table triggers
+-- maybe jsonb constraints
+-- actions (delete)
+BEGIN;
+
+CREATE TYPE usertitle_status_t AS ENUM ('finished', 'planned', 'dropped', 'in-progress');
+CREATE TYPE storage_type_t AS ENUM ('local', 's3');
+CREATE TYPE title_status_t AS ENUM ('finished', 'ongoing', 'planned');
+CREATE TYPE release_season_t AS ENUM ('winter', 'spring', 'summer', 'fall');
+
+CREATE TABLE providers (
+ provider_id serial PRIMARY KEY,
+ provider_name varchar(64) NOT NULL
+);
+
+CREATE TABLE tags (
+ tag_id serial PRIMARY KEY,
+ tag_names jsonb NOT NULL --mb constraints
+);
+
+CREATE TABLE images (
+ image_id serial PRIMARY KEY,
+ storage_type storage_type_t NOT NULL,
+ image_path varchar(256) UNIQUE NOT NULL
+);
+
+CREATE TABLE users (
+ user_id serial PRIMARY KEY,
+ avatar_id int REFERENCES images (image_id),
+ passhash text NOT NULL,
+ mail varchar(64) CHECK (mail ~ '[a-zA-Z0-9._-]+@[a-zA-Z0-9._-]+\.[a-zA-Z0-9_-]+'),
+ nickname varchar(16) NOT NULL CHECK (nickname ~ '^[a-zA-Z0-9_-]+$'),
+ disp_name varchar(32),
+ user_desc varchar(512),
+ creation_date timestamp NOT NULL
+);
+
+CREATE TABLE studios (
+ studio_id serial PRIMARY KEY,
+ studio_name varchar(64) UNIQUE,
+ illust_id int REFERENCES images (image_id),
+ studio_desc text
+);
+
+CREATE TABLE titles (
+ title_id serial PRIMARY KEY,
+ title_names jsonb NOT NULL,
+ studio_id int NOT NULL REFERENCES studios,
+ poster_id int REFERENCES images (image_id),
+ signal_ids int[] NOT NULL,
+ title_status title_status_t NOT NULL,
+ rating float CHECK (rating > 0 AND rating <= 10), --by trigger
+ rating_count int CHECK (rating_count >= 0), --by trigger
+ release_year int CHECK (release_year >= 1900),
+ release_season release_season_t,
+ season int CHECK (season >= 0),
+ episodes_aired int CHECK (episodes_aired >= 0),
+ episodes_all int CHECK (episodes_all >= 0),
+ episodes_len jsonb,
+ CHECK ((episodes_aired IS NULL AND episodes_all IS NULL)
+ OR (episodes_aired IS NOT NULL AND episodes_all IS NOT NULL
+ AND episodes_aired <= episodes_all))
+);
+
+CREATE TABLE reviews (
+ review_id serial PRIMARY KEY,
+ user_id int NOT NULL REFERENCES users,
+ title_id int NOT NULL REFERENCES titles,
+ image_ids int[],
+ review_text text NOT NULL,
+ creation_date timestamp NOT NULL
+);
+
+CREATE TABLE usertitles (
+ usertitle_id serial PRIMARY KEY,
+ user_id int NOT NULL REFERENCES users,
+ title_id int NOT NULL REFERENCES titles,
+ status usertitle_status_t NOT NULL,
+ rate int CHECK (rate > 0 AND rate <= 10),
+ review_id int REFERENCES reviews
+);
+
+CREATE TABLE title_tags (
+ PRIMARY KEY (title_id, tag_id),
+ title_id int NOT NULL REFERENCES titles,
+ tag_id int NOT NULL REFERENCES tags
+);
+
+CREATE TABLE signals (
+ signal_id serial PRIMARY KEY,
+ raw_data jsonb NOT NULL,
+ provider_id int NOT NULL REFERENCES providers,
+ dirty bool NOT NULL
+);
+
+COMMIT;
\ No newline at end of file
diff --git a/modules/sql/sqlc-generate.yaml b/modules/sql/sqlc-generate.yaml
new file mode 100644
index 0000000..8a625de
--- /dev/null
+++ b/modules/sql/sqlc-generate.yaml
@@ -0,0 +1,13 @@
+version: "2"
+sql:
+ - engine: "postgresql"
+ queries: "query.sql"
+ schema: "scheme.sql"
+ gen:
+ go:
+ package: "nyanimedb.backend"
+ out: "sqlc"
+ sql_package: "pgx/v5"
+ sql_driver: "github.com/lib/pq"
+ emit_db_tags: true
+ emit_exact_table_names: true
\ No newline at end of file
diff --git a/modules/sql/sqlc.yaml b/modules/sql/sqlc.yaml
new file mode 100644
index 0000000..079626a
--- /dev/null
+++ b/modules/sql/sqlc.yaml
@@ -0,0 +1,14 @@
+version: "2"
+sql:
+ - engine: "postgresql"
+ queries: "query.sql"
+ schema: "scheme.sql"
+ gen:
+ go:
+ package: "nyanimedb_backend"
+ out: "sqlc"
+ sql_package: "pgx/v5"
+ sql_driver: "github.com/lib/pq"
+ emit_db_tags: true
+ emit_exact_table_names: true
+ emit_json_tags: true
\ No newline at end of file
diff --git a/modules/sql/sqlc/db.go b/modules/sql/sqlc/db.go
new file mode 100644
index 0000000..cdbc865
--- /dev/null
+++ b/modules/sql/sqlc/db.go
@@ -0,0 +1,32 @@
+// Code generated by sqlc. DO NOT EDIT.
+// versions:
+// sqlc v1.30.0
+
+package nyanimedb_backend
+
+import (
+ "context"
+
+ "github.com/jackc/pgx/v5"
+ "github.com/jackc/pgx/v5/pgconn"
+)
+
+type DBTX interface {
+ Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error)
+ Query(context.Context, string, ...interface{}) (pgx.Rows, error)
+ QueryRow(context.Context, string, ...interface{}) pgx.Row
+}
+
+func New(db DBTX) *Queries {
+ return &Queries{db: db}
+}
+
+type Queries struct {
+ db DBTX
+}
+
+func (q *Queries) WithTx(tx pgx.Tx) *Queries {
+ return &Queries{
+ db: tx,
+ }
+}
diff --git a/modules/sql/sqlc/models.go b/modules/sql/sqlc/models.go
new file mode 100644
index 0000000..e7aeb3c
--- /dev/null
+++ b/modules/sql/sqlc/models.go
@@ -0,0 +1,266 @@
+// Code generated by sqlc. DO NOT EDIT.
+// versions:
+// sqlc v1.30.0
+
+package nyanimedb_backend
+
+import (
+ "database/sql/driver"
+ "fmt"
+
+ "github.com/jackc/pgx/v5/pgtype"
+)
+
+type ReleaseSeasonT string
+
+const (
+ ReleaseSeasonTWinter ReleaseSeasonT = "winter"
+ ReleaseSeasonTSpring ReleaseSeasonT = "spring"
+ ReleaseSeasonTSummer ReleaseSeasonT = "summer"
+ ReleaseSeasonTFall ReleaseSeasonT = "fall"
+)
+
+func (e *ReleaseSeasonT) Scan(src interface{}) error {
+ switch s := src.(type) {
+ case []byte:
+ *e = ReleaseSeasonT(s)
+ case string:
+ *e = ReleaseSeasonT(s)
+ default:
+ return fmt.Errorf("unsupported scan type for ReleaseSeasonT: %T", src)
+ }
+ return nil
+}
+
+type NullReleaseSeasonT struct {
+ ReleaseSeasonT ReleaseSeasonT `json:"release_season_t"`
+ Valid bool `json:"valid"` // Valid is true if ReleaseSeasonT is not NULL
+}
+
+// Scan implements the Scanner interface.
+func (ns *NullReleaseSeasonT) Scan(value interface{}) error {
+ if value == nil {
+ ns.ReleaseSeasonT, ns.Valid = "", false
+ return nil
+ }
+ ns.Valid = true
+ return ns.ReleaseSeasonT.Scan(value)
+}
+
+// Value implements the driver Valuer interface.
+func (ns NullReleaseSeasonT) Value() (driver.Value, error) {
+ if !ns.Valid {
+ return nil, nil
+ }
+ return string(ns.ReleaseSeasonT), nil
+}
+
+type StorageTypeT string
+
+const (
+ StorageTypeTLocal StorageTypeT = "local"
+ StorageTypeTS3 StorageTypeT = "s3"
+)
+
+func (e *StorageTypeT) Scan(src interface{}) error {
+ switch s := src.(type) {
+ case []byte:
+ *e = StorageTypeT(s)
+ case string:
+ *e = StorageTypeT(s)
+ default:
+ return fmt.Errorf("unsupported scan type for StorageTypeT: %T", src)
+ }
+ return nil
+}
+
+type NullStorageTypeT struct {
+ StorageTypeT StorageTypeT `json:"storage_type_t"`
+ Valid bool `json:"valid"` // Valid is true if StorageTypeT is not NULL
+}
+
+// Scan implements the Scanner interface.
+func (ns *NullStorageTypeT) Scan(value interface{}) error {
+ if value == nil {
+ ns.StorageTypeT, ns.Valid = "", false
+ return nil
+ }
+ ns.Valid = true
+ return ns.StorageTypeT.Scan(value)
+}
+
+// Value implements the driver Valuer interface.
+func (ns NullStorageTypeT) Value() (driver.Value, error) {
+ if !ns.Valid {
+ return nil, nil
+ }
+ return string(ns.StorageTypeT), nil
+}
+
+type TitleStatusT string
+
+const (
+ TitleStatusTFinished TitleStatusT = "finished"
+ TitleStatusTOngoing TitleStatusT = "ongoing"
+ TitleStatusTPlanned TitleStatusT = "planned"
+)
+
+func (e *TitleStatusT) Scan(src interface{}) error {
+ switch s := src.(type) {
+ case []byte:
+ *e = TitleStatusT(s)
+ case string:
+ *e = TitleStatusT(s)
+ default:
+ return fmt.Errorf("unsupported scan type for TitleStatusT: %T", src)
+ }
+ return nil
+}
+
+type NullTitleStatusT struct {
+ TitleStatusT TitleStatusT `json:"title_status_t"`
+ Valid bool `json:"valid"` // Valid is true if TitleStatusT is not NULL
+}
+
+// Scan implements the Scanner interface.
+func (ns *NullTitleStatusT) Scan(value interface{}) error {
+ if value == nil {
+ ns.TitleStatusT, ns.Valid = "", false
+ return nil
+ }
+ ns.Valid = true
+ return ns.TitleStatusT.Scan(value)
+}
+
+// Value implements the driver Valuer interface.
+func (ns NullTitleStatusT) Value() (driver.Value, error) {
+ if !ns.Valid {
+ return nil, nil
+ }
+ return string(ns.TitleStatusT), nil
+}
+
+type UsertitleStatusT string
+
+const (
+ UsertitleStatusTFinished UsertitleStatusT = "finished"
+ UsertitleStatusTPlanned UsertitleStatusT = "planned"
+ UsertitleStatusTDropped UsertitleStatusT = "dropped"
+ UsertitleStatusTInProgress UsertitleStatusT = "in-progress"
+)
+
+func (e *UsertitleStatusT) Scan(src interface{}) error {
+ switch s := src.(type) {
+ case []byte:
+ *e = UsertitleStatusT(s)
+ case string:
+ *e = UsertitleStatusT(s)
+ default:
+ return fmt.Errorf("unsupported scan type for UsertitleStatusT: %T", src)
+ }
+ return nil
+}
+
+type NullUsertitleStatusT struct {
+ UsertitleStatusT UsertitleStatusT `json:"usertitle_status_t"`
+ Valid bool `json:"valid"` // Valid is true if UsertitleStatusT is not NULL
+}
+
+// Scan implements the Scanner interface.
+func (ns *NullUsertitleStatusT) Scan(value interface{}) error {
+ if value == nil {
+ ns.UsertitleStatusT, ns.Valid = "", false
+ return nil
+ }
+ ns.Valid = true
+ return ns.UsertitleStatusT.Scan(value)
+}
+
+// Value implements the driver Valuer interface.
+func (ns NullUsertitleStatusT) Value() (driver.Value, error) {
+ if !ns.Valid {
+ return nil, nil
+ }
+ return string(ns.UsertitleStatusT), nil
+}
+
+type Images struct {
+ ImageID int32 `db:"image_id" json:"image_id"`
+ StorageType StorageTypeT `db:"storage_type" json:"storage_type"`
+ ImagePath string `db:"image_path" json:"image_path"`
+}
+
+type Providers struct {
+ ProviderID int32 `db:"provider_id" json:"provider_id"`
+ ProviderName string `db:"provider_name" json:"provider_name"`
+}
+
+type Reviews struct {
+ ReviewID int32 `db:"review_id" json:"review_id"`
+ UserID int32 `db:"user_id" json:"user_id"`
+ TitleID int32 `db:"title_id" json:"title_id"`
+ ImageIds []int32 `db:"image_ids" json:"image_ids"`
+ ReviewText string `db:"review_text" json:"review_text"`
+ CreationDate pgtype.Timestamp `db:"creation_date" json:"creation_date"`
+}
+
+type Signals struct {
+ SignalID int32 `db:"signal_id" json:"signal_id"`
+ RawData []byte `db:"raw_data" json:"raw_data"`
+ ProviderID int32 `db:"provider_id" json:"provider_id"`
+ Dirty bool `db:"dirty" json:"dirty"`
+}
+
+type Studios struct {
+ StudioID int32 `db:"studio_id" json:"studio_id"`
+ StudioName pgtype.Text `db:"studio_name" json:"studio_name"`
+ IllustID pgtype.Int4 `db:"illust_id" json:"illust_id"`
+ StudioDesc pgtype.Text `db:"studio_desc" json:"studio_desc"`
+}
+
+type Tags struct {
+ TagID int32 `db:"tag_id" json:"tag_id"`
+ TagNames []byte `db:"tag_names" json:"tag_names"`
+}
+
+type TitleTags struct {
+ TitleID int32 `db:"title_id" json:"title_id"`
+ TagID int32 `db:"tag_id" json:"tag_id"`
+}
+
+type Titles struct {
+ TitleID int32 `db:"title_id" json:"title_id"`
+ TitleNames []byte `db:"title_names" json:"title_names"`
+ StudioID int32 `db:"studio_id" json:"studio_id"`
+ PosterID pgtype.Int4 `db:"poster_id" json:"poster_id"`
+ SignalIds []int32 `db:"signal_ids" json:"signal_ids"`
+ TitleStatus TitleStatusT `db:"title_status" json:"title_status"`
+ Rating pgtype.Float8 `db:"rating" json:"rating"`
+ RatingCount pgtype.Int4 `db:"rating_count" json:"rating_count"`
+ ReleaseYear pgtype.Int4 `db:"release_year" json:"release_year"`
+ ReleaseSeason NullReleaseSeasonT `db:"release_season" json:"release_season"`
+ Season pgtype.Int4 `db:"season" json:"season"`
+ EpisodesAired pgtype.Int4 `db:"episodes_aired" json:"episodes_aired"`
+ EpisodesAll pgtype.Int4 `db:"episodes_all" json:"episodes_all"`
+ EpisodesLen []byte `db:"episodes_len" json:"episodes_len"`
+}
+
+type Users struct {
+ UserID int32 `db:"user_id" json:"user_id"`
+ AvatarID pgtype.Int4 `db:"avatar_id" json:"avatar_id"`
+ Passhash string `db:"passhash" json:"passhash"`
+ Mail pgtype.Text `db:"mail" json:"mail"`
+ Nickname string `db:"nickname" json:"nickname"`
+ DispName pgtype.Text `db:"disp_name" json:"disp_name"`
+ UserDesc pgtype.Text `db:"user_desc" json:"user_desc"`
+ CreationDate pgtype.Timestamp `db:"creation_date" json:"creation_date"`
+}
+
+type Usertitles struct {
+ UsertitleID int32 `db:"usertitle_id" json:"usertitle_id"`
+ UserID int32 `db:"user_id" json:"user_id"`
+ TitleID int32 `db:"title_id" json:"title_id"`
+ Status UsertitleStatusT `db:"status" json:"status"`
+ Rate pgtype.Int4 `db:"rate" json:"rate"`
+ ReviewID pgtype.Int4 `db:"review_id" json:"review_id"`
+}
diff --git a/modules/sql/sqlc/query.sql.go b/modules/sql/sqlc/query.sql.go
new file mode 100644
index 0000000..1fc06ac
--- /dev/null
+++ b/modules/sql/sqlc/query.sql.go
@@ -0,0 +1,712 @@
+// Code generated by sqlc. DO NOT EDIT.
+// versions:
+// sqlc v1.30.0
+// source: query.sql
+
+package db
+
+import (
+ "context"
+
+ "github.com/jackc/pgx/v5/pgtype"
+)
+
+const createImage = `-- name: CreateImage :one
+INSERT INTO images (storage_type, image_path)
+VALUES ($1, $2)
+RETURNING image_id, storage_type, image_path
+`
+
+type CreateImageParams struct {
+ StorageType StorageTypeT `db:"storage_type" json:"storage_type"`
+ ImagePath string `db:"image_path" json:"image_path"`
+}
+
+func (q *Queries) CreateImage(ctx context.Context, arg CreateImageParams) (Images, error) {
+ row := q.db.QueryRow(ctx, createImage, arg.StorageType, arg.ImagePath)
+ var i Images
+ err := row.Scan(&i.ImageID, &i.StorageType, &i.ImagePath)
+ return i, err
+}
+
+const createReview = `-- name: CreateReview :one
+INSERT INTO reviews (user_id, title_id, image_ids, review_text, creation_date)
+VALUES ($1, $2, $3, $4, $5)
+RETURNING review_id, user_id, title_id, image_ids, review_text, creation_date
+`
+
+type CreateReviewParams struct {
+ UserID int32 `db:"user_id" json:"user_id"`
+ TitleID int32 `db:"title_id" json:"title_id"`
+ ImageIds []int32 `db:"image_ids" json:"image_ids"`
+ ReviewText string `db:"review_text" json:"review_text"`
+ CreationDate pgtype.Timestamp `db:"creation_date" json:"creation_date"`
+}
+
+func (q *Queries) CreateReview(ctx context.Context, arg CreateReviewParams) (Reviews, error) {
+ row := q.db.QueryRow(ctx, createReview,
+ arg.UserID,
+ arg.TitleID,
+ arg.ImageIds,
+ arg.ReviewText,
+ arg.CreationDate,
+ )
+ var i Reviews
+ err := row.Scan(
+ &i.ReviewID,
+ &i.UserID,
+ &i.TitleID,
+ &i.ImageIds,
+ &i.ReviewText,
+ &i.CreationDate,
+ )
+ return i, err
+}
+
+const createUser = `-- name: CreateUser :one
+INSERT INTO users (avatar_id, passhash, mail, nickname, disp_name, user_desc, creation_date)
+VALUES ($1, $2, $3, $4, $5, $6, $7)
+RETURNING user_id, avatar_id, nickname, disp_name, user_desc, creation_date
+`
+
+type CreateUserParams struct {
+ AvatarID pgtype.Int4 `db:"avatar_id" json:"avatar_id"`
+ Passhash string `db:"passhash" json:"passhash"`
+ Mail pgtype.Text `db:"mail" json:"mail"`
+ Nickname string `db:"nickname" json:"nickname"`
+ DispName pgtype.Text `db:"disp_name" json:"disp_name"`
+ UserDesc pgtype.Text `db:"user_desc" json:"user_desc"`
+ CreationDate pgtype.Timestamp `db:"creation_date" json:"creation_date"`
+}
+
+type CreateUserRow struct {
+ UserID int32 `db:"user_id" json:"user_id"`
+ AvatarID pgtype.Int4 `db:"avatar_id" json:"avatar_id"`
+ Nickname string `db:"nickname" json:"nickname"`
+ DispName pgtype.Text `db:"disp_name" json:"disp_name"`
+ UserDesc pgtype.Text `db:"user_desc" json:"user_desc"`
+ CreationDate pgtype.Timestamp `db:"creation_date" json:"creation_date"`
+}
+
+func (q *Queries) CreateUser(ctx context.Context, arg CreateUserParams) (CreateUserRow, error) {
+ row := q.db.QueryRow(ctx, createUser,
+ arg.AvatarID,
+ arg.Passhash,
+ arg.Mail,
+ arg.Nickname,
+ arg.DispName,
+ arg.UserDesc,
+ arg.CreationDate,
+ )
+ var i CreateUserRow
+ err := row.Scan(
+ &i.UserID,
+ &i.AvatarID,
+ &i.Nickname,
+ &i.DispName,
+ &i.UserDesc,
+ &i.CreationDate,
+ )
+ return i, err
+}
+
+const createUserTitle = `-- name: CreateUserTitle :one
+INSERT INTO usertitles (user_id, title_id, status, rate, review_id)
+VALUES ($1, $2, $3, $4, $5)
+RETURNING usertitle_id, user_id, title_id, status, rate, review_id
+`
+
+type CreateUserTitleParams struct {
+ UserID int32 `db:"user_id" json:"user_id"`
+ TitleID int32 `db:"title_id" json:"title_id"`
+ Status UsertitleStatusT `db:"status" json:"status"`
+ Rate pgtype.Int4 `db:"rate" json:"rate"`
+ ReviewID pgtype.Int4 `db:"review_id" json:"review_id"`
+}
+
+func (q *Queries) CreateUserTitle(ctx context.Context, arg CreateUserTitleParams) (Usertitles, error) {
+ row := q.db.QueryRow(ctx, createUserTitle,
+ arg.UserID,
+ arg.TitleID,
+ arg.Status,
+ arg.Rate,
+ arg.ReviewID,
+ )
+ var i Usertitles
+ err := row.Scan(
+ &i.UsertitleID,
+ &i.UserID,
+ &i.TitleID,
+ &i.Status,
+ &i.Rate,
+ &i.ReviewID,
+ )
+ return i, err
+}
+
+const deleteReview = `-- name: DeleteReview :exec
+DELETE FROM reviews
+WHERE review_id = $1
+`
+
+func (q *Queries) DeleteReview(ctx context.Context, reviewID int32) error {
+ _, err := q.db.Exec(ctx, deleteReview, reviewID)
+ return err
+}
+
+const deleteUser = `-- name: DeleteUser :exec
+DELETE FROM users
+WHERE user_id = $1
+`
+
+func (q *Queries) DeleteUser(ctx context.Context, userID int32) error {
+ _, err := q.db.Exec(ctx, deleteUser, userID)
+ return err
+}
+
+const deleteUserTitle = `-- name: DeleteUserTitle :exec
+DELETE FROM usertitles
+WHERE user_id = $1 AND ($2::int IS NULL OR title_id = $2)
+`
+
+type DeleteUserTitleParams struct {
+ UserID int32 `db:"user_id" json:"user_id"`
+ Column2 int32 `db:"column_2" json:"column_2"`
+}
+
+func (q *Queries) DeleteUserTitle(ctx context.Context, arg DeleteUserTitleParams) error {
+ _, err := q.db.Exec(ctx, deleteUserTitle, arg.UserID, arg.Column2)
+ return err
+}
+
+const getImageByID = `-- name: GetImageByID :one
+SELECT image_id, storage_type, image_path
+FROM images
+WHERE image_id = $1
+`
+
+func (q *Queries) GetImageByID(ctx context.Context, imageID int32) (Images, error) {
+ row := q.db.QueryRow(ctx, getImageByID, imageID)
+ var i Images
+ err := row.Scan(&i.ImageID, &i.StorageType, &i.ImagePath)
+ return i, err
+}
+
+const getReviewByID = `-- name: GetReviewByID :one
+SELECT review_id, user_id, title_id, image_ids, review_text, creation_date
+FROM reviews
+WHERE review_id = $1
+`
+
+func (q *Queries) GetReviewByID(ctx context.Context, reviewID int32) (Reviews, error) {
+ row := q.db.QueryRow(ctx, getReviewByID, reviewID)
+ var i Reviews
+ err := row.Scan(
+ &i.ReviewID,
+ &i.UserID,
+ &i.TitleID,
+ &i.ImageIds,
+ &i.ReviewText,
+ &i.CreationDate,
+ )
+ return i, err
+}
+
+const getTitleByID = `-- name: GetTitleByID :one
+SELECT title_id, title_names, studio_id, poster_id, signal_ids,
+ title_status, rating, rating_count, release_year, release_season,
+ season, episodes_aired, episodes_all, episodes_len
+FROM titles
+WHERE title_id = $1
+`
+
+func (q *Queries) GetTitleByID(ctx context.Context, titleID int32) (Titles, error) {
+ row := q.db.QueryRow(ctx, getTitleByID, titleID)
+ var i Titles
+ err := row.Scan(
+ &i.TitleID,
+ &i.TitleNames,
+ &i.StudioID,
+ &i.PosterID,
+ &i.SignalIds,
+ &i.TitleStatus,
+ &i.Rating,
+ &i.RatingCount,
+ &i.ReleaseYear,
+ &i.ReleaseSeason,
+ &i.Season,
+ &i.EpisodesAired,
+ &i.EpisodesAll,
+ &i.EpisodesLen,
+ )
+ return i, err
+}
+
+const getUserByID = `-- name: GetUserByID :one
+SELECT user_id, avatar_id, passhash, mail, nickname, disp_name, user_desc, creation_date
+FROM users
+WHERE user_id = $1
+`
+
+func (q *Queries) GetUserByID(ctx context.Context, userID int32) (Users, error) {
+ row := q.db.QueryRow(ctx, getUserByID, userID)
+ var i Users
+ err := row.Scan(
+ &i.UserID,
+ &i.AvatarID,
+ &i.Passhash,
+ &i.Mail,
+ &i.Nickname,
+ &i.DispName,
+ &i.UserDesc,
+ &i.CreationDate,
+ )
+ return i, err
+}
+
+const getUserTitle = `-- name: GetUserTitle :one
+SELECT usertitle_id, user_id, title_id, status, rate, review_id
+FROM usertitles
+WHERE user_id = $1 AND title_id = $2
+`
+
+type GetUserTitleParams struct {
+ UserID int32 `db:"user_id" json:"user_id"`
+ TitleID int32 `db:"title_id" json:"title_id"`
+}
+
+func (q *Queries) GetUserTitle(ctx context.Context, arg GetUserTitleParams) (Usertitles, error) {
+ row := q.db.QueryRow(ctx, getUserTitle, arg.UserID, arg.TitleID)
+ var i Usertitles
+ err := row.Scan(
+ &i.UsertitleID,
+ &i.UserID,
+ &i.TitleID,
+ &i.Status,
+ &i.Rate,
+ &i.ReviewID,
+ )
+ return i, err
+}
+
+const listReviewsByTitle = `-- name: ListReviewsByTitle :many
+SELECT review_id, user_id, title_id, image_ids, review_text, creation_date
+FROM reviews
+WHERE title_id = $1
+ORDER BY creation_date DESC
+LIMIT $2 OFFSET $3
+`
+
+type ListReviewsByTitleParams struct {
+ TitleID int32 `db:"title_id" json:"title_id"`
+ Limit int32 `db:"limit" json:"limit"`
+ Offset int32 `db:"offset" json:"offset"`
+}
+
+func (q *Queries) ListReviewsByTitle(ctx context.Context, arg ListReviewsByTitleParams) ([]Reviews, error) {
+ rows, err := q.db.Query(ctx, listReviewsByTitle, arg.TitleID, arg.Limit, arg.Offset)
+ if err != nil {
+ return nil, err
+ }
+ defer rows.Close()
+ var items []Reviews
+ for rows.Next() {
+ var i Reviews
+ if err := rows.Scan(
+ &i.ReviewID,
+ &i.UserID,
+ &i.TitleID,
+ &i.ImageIds,
+ &i.ReviewText,
+ &i.CreationDate,
+ ); err != nil {
+ return nil, err
+ }
+ items = append(items, i)
+ }
+ if err := rows.Err(); err != nil {
+ return nil, err
+ }
+ return items, nil
+}
+
+const listReviewsByUser = `-- name: ListReviewsByUser :many
+SELECT review_id, user_id, title_id, image_ids, review_text, creation_date
+FROM reviews
+WHERE user_id = $1
+ORDER BY creation_date DESC
+LIMIT $2 OFFSET $3
+`
+
+type ListReviewsByUserParams struct {
+ UserID int32 `db:"user_id" json:"user_id"`
+ Limit int32 `db:"limit" json:"limit"`
+ Offset int32 `db:"offset" json:"offset"`
+}
+
+func (q *Queries) ListReviewsByUser(ctx context.Context, arg ListReviewsByUserParams) ([]Reviews, error) {
+ rows, err := q.db.Query(ctx, listReviewsByUser, arg.UserID, arg.Limit, arg.Offset)
+ if err != nil {
+ return nil, err
+ }
+ defer rows.Close()
+ var items []Reviews
+ for rows.Next() {
+ var i Reviews
+ if err := rows.Scan(
+ &i.ReviewID,
+ &i.UserID,
+ &i.TitleID,
+ &i.ImageIds,
+ &i.ReviewText,
+ &i.CreationDate,
+ ); err != nil {
+ return nil, err
+ }
+ items = append(items, i)
+ }
+ if err := rows.Err(); err != nil {
+ return nil, err
+ }
+ return items, nil
+}
+
+const listTags = `-- name: ListTags :many
+SELECT tag_id, tag_names
+FROM tags
+ORDER BY tag_id
+LIMIT $1 OFFSET $2
+`
+
+type ListTagsParams struct {
+ Limit int32 `db:"limit" json:"limit"`
+ Offset int32 `db:"offset" json:"offset"`
+}
+
+func (q *Queries) ListTags(ctx context.Context, arg ListTagsParams) ([]Tags, error) {
+ rows, err := q.db.Query(ctx, listTags, arg.Limit, arg.Offset)
+ if err != nil {
+ return nil, err
+ }
+ defer rows.Close()
+ var items []Tags
+ for rows.Next() {
+ var i Tags
+ if err := rows.Scan(&i.TagID, &i.TagNames); err != nil {
+ return nil, err
+ }
+ items = append(items, i)
+ }
+ if err := rows.Err(); err != nil {
+ return nil, err
+ }
+ return items, nil
+}
+
+const listTitles = `-- name: ListTitles :many
+SELECT title_id, title_names, studio_id, poster_id, signal_ids,
+ title_status, rating, rating_count, release_year, release_season,
+ season, episodes_aired, episodes_all, episodes_len
+FROM titles
+ORDER BY title_id
+LIMIT $1 OFFSET $2
+`
+
+type ListTitlesParams struct {
+ Limit int32 `db:"limit" json:"limit"`
+ Offset int32 `db:"offset" json:"offset"`
+}
+
+func (q *Queries) ListTitles(ctx context.Context, arg ListTitlesParams) ([]Titles, error) {
+ rows, err := q.db.Query(ctx, listTitles, arg.Limit, arg.Offset)
+ if err != nil {
+ return nil, err
+ }
+ defer rows.Close()
+ var items []Titles
+ for rows.Next() {
+ var i Titles
+ if err := rows.Scan(
+ &i.TitleID,
+ &i.TitleNames,
+ &i.StudioID,
+ &i.PosterID,
+ &i.SignalIds,
+ &i.TitleStatus,
+ &i.Rating,
+ &i.RatingCount,
+ &i.ReleaseYear,
+ &i.ReleaseSeason,
+ &i.Season,
+ &i.EpisodesAired,
+ &i.EpisodesAll,
+ &i.EpisodesLen,
+ ); err != nil {
+ return nil, err
+ }
+ items = append(items, i)
+ }
+ if err := rows.Err(); err != nil {
+ return nil, err
+ }
+ return items, nil
+}
+
+const listUserTitles = `-- name: ListUserTitles :many
+SELECT usertitle_id, user_id, title_id, status, rate, review_id
+FROM usertitles
+WHERE user_id = $1
+ORDER BY usertitle_id
+LIMIT $2 OFFSET $3
+`
+
+type ListUserTitlesParams struct {
+ UserID int32 `db:"user_id" json:"user_id"`
+ Limit int32 `db:"limit" json:"limit"`
+ Offset int32 `db:"offset" json:"offset"`
+}
+
+func (q *Queries) ListUserTitles(ctx context.Context, arg ListUserTitlesParams) ([]Usertitles, error) {
+ rows, err := q.db.Query(ctx, listUserTitles, arg.UserID, arg.Limit, arg.Offset)
+ if err != nil {
+ return nil, err
+ }
+ defer rows.Close()
+ var items []Usertitles
+ for rows.Next() {
+ var i Usertitles
+ if err := rows.Scan(
+ &i.UsertitleID,
+ &i.UserID,
+ &i.TitleID,
+ &i.Status,
+ &i.Rate,
+ &i.ReviewID,
+ ); err != nil {
+ return nil, err
+ }
+ items = append(items, i)
+ }
+ if err := rows.Err(); err != nil {
+ return nil, err
+ }
+ return items, nil
+}
+
+const listUsers = `-- name: ListUsers :many
+SELECT user_id, avatar_id, passhash, mail, nickname, disp_name, user_desc, creation_date
+FROM users
+ORDER BY user_id
+LIMIT $1 OFFSET $2
+`
+
+type ListUsersParams struct {
+ Limit int32 `db:"limit" json:"limit"`
+ Offset int32 `db:"offset" json:"offset"`
+}
+
+func (q *Queries) ListUsers(ctx context.Context, arg ListUsersParams) ([]Users, error) {
+ rows, err := q.db.Query(ctx, listUsers, arg.Limit, arg.Offset)
+ if err != nil {
+ return nil, err
+ }
+ defer rows.Close()
+ var items []Users
+ for rows.Next() {
+ var i Users
+ if err := rows.Scan(
+ &i.UserID,
+ &i.AvatarID,
+ &i.Passhash,
+ &i.Mail,
+ &i.Nickname,
+ &i.DispName,
+ &i.UserDesc,
+ &i.CreationDate,
+ ); err != nil {
+ return nil, err
+ }
+ items = append(items, i)
+ }
+ if err := rows.Err(); err != nil {
+ return nil, err
+ }
+ return items, nil
+}
+
+const updateReview = `-- name: UpdateReview :one
+UPDATE reviews
+SET
+ image_ids = COALESCE($1, image_ids),
+ review_text = COALESCE($2, review_text)
+WHERE review_id = $3
+RETURNING review_id, user_id, title_id, image_ids, review_text, creation_date
+`
+
+type UpdateReviewParams struct {
+ ImageIds []int32 `db:"image_ids" json:"image_ids"`
+ ReviewText pgtype.Text `db:"review_text" json:"review_text"`
+ ReviewID int32 `db:"review_id" json:"review_id"`
+}
+
+func (q *Queries) UpdateReview(ctx context.Context, arg UpdateReviewParams) (Reviews, error) {
+ row := q.db.QueryRow(ctx, updateReview, arg.ImageIds, arg.ReviewText, arg.ReviewID)
+ var i Reviews
+ err := row.Scan(
+ &i.ReviewID,
+ &i.UserID,
+ &i.TitleID,
+ &i.ImageIds,
+ &i.ReviewText,
+ &i.CreationDate,
+ )
+ return i, err
+}
+
+const updateTitle = `-- name: UpdateTitle :one
+UPDATE titles
+SET
+ title_names = COALESCE($1, title_names),
+ studio_id = COALESCE($2, studio_id),
+ poster_id = COALESCE($3, poster_id),
+ signal_ids = COALESCE($4, signal_ids),
+ title_status = COALESCE($5, title_status),
+ release_year = COALESCE($6, release_year),
+ release_season = COALESCE($7, release_season),
+ episodes_aired = COALESCE($8, episodes_aired),
+ episodes_all = COALESCE($9, episodes_all),
+ episodes_len = COALESCE($10, episodes_len)
+WHERE title_id = $11
+RETURNING title_id, title_names, studio_id, poster_id, signal_ids, title_status, rating, rating_count, release_year, release_season, season, episodes_aired, episodes_all, episodes_len
+`
+
+type UpdateTitleParams struct {
+ TitleNames []byte `db:"title_names" json:"title_names"`
+ StudioID pgtype.Int4 `db:"studio_id" json:"studio_id"`
+ PosterID pgtype.Int4 `db:"poster_id" json:"poster_id"`
+ SignalIds []int32 `db:"signal_ids" json:"signal_ids"`
+ TitleStatus NullTitleStatusT `db:"title_status" json:"title_status"`
+ ReleaseYear pgtype.Int4 `db:"release_year" json:"release_year"`
+ ReleaseSeason NullReleaseSeasonT `db:"release_season" json:"release_season"`
+ EpisodesAired pgtype.Int4 `db:"episodes_aired" json:"episodes_aired"`
+ EpisodesAll pgtype.Int4 `db:"episodes_all" json:"episodes_all"`
+ EpisodesLen []byte `db:"episodes_len" json:"episodes_len"`
+ TitleID int32 `db:"title_id" json:"title_id"`
+}
+
+func (q *Queries) UpdateTitle(ctx context.Context, arg UpdateTitleParams) (Titles, error) {
+ row := q.db.QueryRow(ctx, updateTitle,
+ arg.TitleNames,
+ arg.StudioID,
+ arg.PosterID,
+ arg.SignalIds,
+ arg.TitleStatus,
+ arg.ReleaseYear,
+ arg.ReleaseSeason,
+ arg.EpisodesAired,
+ arg.EpisodesAll,
+ arg.EpisodesLen,
+ arg.TitleID,
+ )
+ var i Titles
+ err := row.Scan(
+ &i.TitleID,
+ &i.TitleNames,
+ &i.StudioID,
+ &i.PosterID,
+ &i.SignalIds,
+ &i.TitleStatus,
+ &i.Rating,
+ &i.RatingCount,
+ &i.ReleaseYear,
+ &i.ReleaseSeason,
+ &i.Season,
+ &i.EpisodesAired,
+ &i.EpisodesAll,
+ &i.EpisodesLen,
+ )
+ return i, err
+}
+
+const updateUser = `-- name: UpdateUser :one
+UPDATE users
+SET
+ avatar_id = COALESCE($1, avatar_id),
+ disp_name = COALESCE($2, disp_name),
+ user_desc = COALESCE($3, user_desc)
+WHERE user_id = $4
+RETURNING user_id, avatar_id, nickname, disp_name, user_desc, creation_date
+`
+
+type UpdateUserParams struct {
+ AvatarID pgtype.Int4 `db:"avatar_id" json:"avatar_id"`
+ DispName pgtype.Text `db:"disp_name" json:"disp_name"`
+ UserDesc pgtype.Text `db:"user_desc" json:"user_desc"`
+ UserID int32 `db:"user_id" json:"user_id"`
+}
+
+type UpdateUserRow struct {
+ UserID int32 `db:"user_id" json:"user_id"`
+ AvatarID pgtype.Int4 `db:"avatar_id" json:"avatar_id"`
+ Nickname string `db:"nickname" json:"nickname"`
+ DispName pgtype.Text `db:"disp_name" json:"disp_name"`
+ UserDesc pgtype.Text `db:"user_desc" json:"user_desc"`
+ CreationDate pgtype.Timestamp `db:"creation_date" json:"creation_date"`
+}
+
+func (q *Queries) UpdateUser(ctx context.Context, arg UpdateUserParams) (UpdateUserRow, error) {
+ row := q.db.QueryRow(ctx, updateUser,
+ arg.AvatarID,
+ arg.DispName,
+ arg.UserDesc,
+ arg.UserID,
+ )
+ var i UpdateUserRow
+ err := row.Scan(
+ &i.UserID,
+ &i.AvatarID,
+ &i.Nickname,
+ &i.DispName,
+ &i.UserDesc,
+ &i.CreationDate,
+ )
+ return i, err
+}
+
+const updateUserTitle = `-- name: UpdateUserTitle :one
+UPDATE usertitles
+SET
+ status = COALESCE($3, status),
+ rate = COALESCE($4, rate),
+ review_id = COALESCE($5, review_id)
+WHERE user_id = $1 AND title_id = $2
+RETURNING usertitle_id, user_id, title_id, status, rate, review_id
+`
+
+type UpdateUserTitleParams struct {
+ UserID int32 `db:"user_id" json:"user_id"`
+ TitleID int32 `db:"title_id" json:"title_id"`
+ Status NullUsertitleStatusT `db:"status" json:"status"`
+ Rate pgtype.Int4 `db:"rate" json:"rate"`
+ ReviewID pgtype.Int4 `db:"review_id" json:"review_id"`
+}
+
+func (q *Queries) UpdateUserTitle(ctx context.Context, arg UpdateUserTitleParams) (Usertitles, error) {
+ row := q.db.QueryRow(ctx, updateUserTitle,
+ arg.UserID,
+ arg.TitleID,
+ arg.Status,
+ arg.Rate,
+ arg.ReviewID,
+ )
+ var i Usertitles
+ err := row.Scan(
+ &i.UsertitleID,
+ &i.UserID,
+ &i.TitleID,
+ &i.Status,
+ &i.Rate,
+ &i.ReviewID,
+ )
+ return i, err
+}
diff --git a/sql/migrations/000001_init.down.sql b/sql/migrations/000001_init.down.sql
deleted file mode 100644
index dc52d23..0000000
--- a/sql/migrations/000001_init.down.sql
+++ /dev/null
@@ -1,20 +0,0 @@
-DROP TRIGGER IF EXISTS trg_update_title_rating ON usertitles;
-DROP TRIGGER IF EXISTS trg_notify_new_signal ON signals;
-
-DROP FUNCTION IF EXISTS update_title_rating();
-DROP FUNCTION IF EXISTS notify_new_signal();
-
-DROP TABLE IF EXISTS signals;
-DROP TABLE IF EXISTS title_tags;
-DROP TABLE IF EXISTS usertitles;
-DROP TABLE IF EXISTS titles;
-DROP TABLE IF EXISTS studios;
-DROP TABLE IF EXISTS users;
-DROP TABLE IF EXISTS images;
-DROP TABLE IF EXISTS tags;
-DROP TABLE IF EXISTS providers;
-
-DROP TYPE IF EXISTS release_season_t;
-DROP TYPE IF EXISTS title_status_t;
-DROP TYPE IF EXISTS storage_type_t;
-DROP TYPE IF EXISTS usertitle_status_t;
\ No newline at end of file
diff --git a/sql/migrations/000001_init.up.sql b/sql/migrations/000001_init.up.sql
deleted file mode 100644
index 0b7fa33..0000000
--- a/sql/migrations/000001_init.up.sql
+++ /dev/null
@@ -1,141 +0,0 @@
--- TODO:
--- maybe jsonb constraints
--- clean unused images
-CREATE TYPE usertitle_status_t AS ENUM ('finished', 'planned', 'dropped', 'in-progress');
-CREATE TYPE storage_type_t AS ENUM ('local', 's3');
-CREATE TYPE title_status_t AS ENUM ('finished', 'ongoing', 'planned');
-CREATE TYPE release_season_t AS ENUM ('winter', 'spring', 'summer', 'fall');
-
-CREATE TABLE providers (
- id bigint GENERATED ALWAYS AS IDENTITY PRIMARY KEY,
- provider_name text NOT NULL,
- credentials jsonb
-);
-
-CREATE TABLE tags (
- id bigint GENERATED ALWAYS AS IDENTITY PRIMARY KEY,
- tag_names jsonb NOT NULL
-);
-
-CREATE TABLE images (
- id bigint GENERATED ALWAYS AS IDENTITY PRIMARY KEY,
- storage_type storage_type_t NOT NULL,
- image_path text UNIQUE NOT NULL
-);
-
-CREATE TABLE users (
- id bigint GENERATED ALWAYS AS IDENTITY PRIMARY KEY,
- avatar_id bigint REFERENCES images (id),
- passhash text NOT NULL,
- mail text CHECK (mail ~ '[a-zA-Z0-9._-]+@[a-zA-Z0-9._-]+\.[a-zA-Z0-9_-]+'),
- nickname text NOT NULL CHECK (nickname ~ '^[a-zA-Z0-9_-]+$'),
- disp_name text,
- user_desc text,
- creation_date timestamptz NOT NULL,
- last_login timestamptz
-);
-
-CREATE TABLE studios (
- id bigint GENERATED ALWAYS AS IDENTITY PRIMARY KEY,
- studio_name text UNIQUE,
- illust_id bigint REFERENCES images (id),
- studio_desc text
-);
-
-CREATE TABLE titles (
- id bigint GENERATED ALWAYS AS IDENTITY PRIMARY KEY,
- title_names jsonb NOT NULL,
- studio_id bigint NOT NULL REFERENCES studios (id),
- poster_id bigint REFERENCES images (id),
- title_status title_status_t NOT NULL,
- rating float CHECK (rating >= 0 AND rating <= 10),
- rating_count int CHECK (rating_count >= 0),
- release_year int CHECK (release_year >= 1900),
- release_season release_season_t,
- season int CHECK (season >= 0),
- episodes_aired int CHECK (episodes_aired >= 0),
- episodes_all int CHECK (episodes_all >= 0),
- episodes_len jsonb,
- CHECK ((episodes_aired IS NULL AND episodes_all IS NULL)
- OR (episodes_aired IS NOT NULL AND episodes_all IS NOT NULL
- AND episodes_aired <= episodes_all))
-);
-
-CREATE TABLE usertitles (
- PRIMARY KEY (user_id, title_id),
- user_id bigint NOT NULL REFERENCES users (id),
- title_id bigint NOT NULL REFERENCES titles (id),
- status usertitle_status_t NOT NULL,
- rate int CHECK (rate > 0 AND rate <= 10),
- review_text text,
- review_date timestamptz
-);
-
-CREATE TABLE title_tags (
- PRIMARY KEY (title_id, tag_id),
- title_id bigint NOT NULL REFERENCES titles (id),
- tag_id bigint NOT NULL REFERENCES tags (id)
-);
-
-CREATE TABLE signals (
- id bigint GENERATED ALWAYS AS IDENTITY PRIMARY KEY,
- title_id bigint REFERENCES titles (id),
- raw_data jsonb NOT NULL,
- provider_id bigint NOT NULL REFERENCES providers (id),
- pending boolean NOT NULL
-);
-
--- Functions
-CREATE OR REPLACE FUNCTION update_title_rating()
-RETURNS TRIGGER AS $$
-BEGIN
- IF (TG_OP = 'INSERT') OR (TG_OP = 'UPDATE' AND NEW.rate IS DISTINCT FROM OLD.rate) THEN
- UPDATE titles
- SET
- rating = sub.avg_rating,
- rating_count = sub.rating_count
- FROM (
- SELECT
- title_id,
- AVG(rate)::float AS avg_rating,
- COUNT(rate) AS rating_count
- FROM usertitles
- WHERE title_id = NEW.title_id AND rate IS NOT NULL
- GROUP BY title_id
- ) AS sub
- WHERE titles.id = sub.title_id;
- END IF;
-
- RETURN NEW;
-END;
-$$ LANGUAGE plpgsql;
-
-CREATE OR REPLACE FUNCTION notify_new_signal()
-RETURNS TRIGGER AS $$
-DECLARE
- payload JSON;
-BEGIN
- payload := json_build_object(
- 'signal_id', NEW.id,
- 'title_id', NEW.title_id,
- 'provider_id', NEW.provider_id,
- 'pending', NEW.pending,
- 'timestamp', NOW()
- );
- PERFORM pg_notify('new_signal', payload::text);
-
- RETURN NEW;
-END;
-$$ LANGUAGE plpgsql;
-
--- Triggers
-
-CREATE TRIGGER trg_update_title_rating
-AFTER INSERT OR UPDATE OF rate ON usertitles
-FOR EACH ROW
-EXECUTE FUNCTION update_title_rating();
-
-CREATE TRIGGER trg_notify_new_signal
-AFTER INSERT ON signals
-FOR EACH ROW
-EXECUTE FUNCTION notify_new_signal();
\ No newline at end of file
diff --git a/sql/queries.sql.go b/sql/queries.sql.go
deleted file mode 100644
index 8f92c2a..0000000
--- a/sql/queries.sql.go
+++ /dev/null
@@ -1,73 +0,0 @@
-// Code generated by sqlc. DO NOT EDIT.
-// versions:
-// sqlc v1.30.0
-// source: queries.sql
-
-package sqlc
-
-import (
- "context"
- "time"
-)
-
-const createImage = `-- name: CreateImage :one
-INSERT INTO images (storage_type, image_path)
-VALUES ($1, $2)
-RETURNING id, storage_type, image_path
-`
-
-type CreateImageParams struct {
- StorageType StorageTypeT `json:"storage_type"`
- ImagePath string `json:"image_path"`
-}
-
-func (q *Queries) CreateImage(ctx context.Context, arg CreateImageParams) (Image, error) {
- row := q.db.QueryRow(ctx, createImage, arg.StorageType, arg.ImagePath)
- var i Image
- err := row.Scan(&i.ID, &i.StorageType, &i.ImagePath)
- return i, err
-}
-
-const getImageByID = `-- name: GetImageByID :one
-SELECT id, storage_type, image_path
-FROM images
-WHERE id = $1
-`
-
-func (q *Queries) GetImageByID(ctx context.Context, id int64) (Image, error) {
- row := q.db.QueryRow(ctx, getImageByID, id)
- var i Image
- err := row.Scan(&i.ID, &i.StorageType, &i.ImagePath)
- return i, err
-}
-
-const getUserByID = `-- name: GetUserByID :one
-SELECT id, avatar_id, mail, nickname, disp_name, user_desc, creation_date
-FROM users
-WHERE id = $1
-`
-
-type GetUserByIDRow struct {
- ID int64 `json:"id"`
- AvatarID *int64 `json:"avatar_id"`
- Mail *string `json:"mail"`
- Nickname string `json:"nickname"`
- DispName *string `json:"disp_name"`
- UserDesc *string `json:"user_desc"`
- CreationDate time.Time `json:"creation_date"`
-}
-
-func (q *Queries) GetUserByID(ctx context.Context, id int64) (GetUserByIDRow, error) {
- row := q.db.QueryRow(ctx, getUserByID, id)
- var i GetUserByIDRow
- err := row.Scan(
- &i.ID,
- &i.AvatarID,
- &i.Mail,
- &i.Nickname,
- &i.DispName,
- &i.UserDesc,
- &i.CreationDate,
- )
- return i, err
-}
diff --git a/sql/sqlc.yaml b/sql/sqlc.yaml
deleted file mode 100644
index f44761e..0000000
--- a/sql/sqlc.yaml
+++ /dev/null
@@ -1,27 +0,0 @@
-version: "2"
-sql:
- - engine: "postgresql"
- queries:
- - "../modules/backend/queries.sql"
- schema: "migrations"
- gen:
- go:
- package: "sqlc"
- out: "."
- sql_package: "pgx/v5"
- sql_driver: "github.com/jackc/pgx/v5"
- emit_json_tags: true
- emit_pointers_for_null_types: true
- overrides:
- - db_type: "uuid"
- nullable: false
- go_type:
- import: "github.com/gofrs/uuid"
- package: "gofrsuuid"
- type: UUID
- pointer: true
- - db_type: "timestamptz"
- nullable: false
- go_type:
- import: "time"
- type: "Time"
\ No newline at end of file
-
-
- {user.avatar_id ? (
- 
- ) : (
-
-
-
- ) : (
-
- {user.disp_name?.[0] || "U"}
-
- )}
-
-
- {user.disp_name || user.nickname}
-@{user.nickname}
- {user.user_desc &&{user.user_desc}
} -- Joined: {new Date(user.creation_date).toLocaleDateString()} -
-