14728457306

Committed 29 Apr 2025 09:56AM UTC coverage: 26.356% (-6.8%) from 33.177%

Build # 14728457306

Build Type

push

github

Committed by

web-flow

Commit Message

Bump up go version to 1.24, upgrade dependencies

* Bump up go version to 1.24, upgrade dependencies
* Upgrade golanci-lint
* Upgrade player dependency
* Update test action for go 1.24

Run Details

2 of 4 new or added lines in 4 files covered. (50.0%)

1102 existing lines in 30 files now uncovered.

4261 of 16167 relevant lines covered (26.36%)

88.04 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/apps/uploads/database/queries.sql.go

// Code generated by sqlc. DO NOT EDIT.
// versions:
//   sqlc v1.19.1
// source: queries.sql

package database

import (
        "context"

        "github.com/sqlc-dev/pqtype"
)

const createURL = `-- name: CreateURL :one
INSERT INTO urls (
    id, user_id, url, filename, size, sd_hash, status
) VALUES (
    $1, $2, $3, $4, 0, '', 'created'
)
RETURNING id, user_id, url, filename, created_at, updated_at, status, size, sd_hash, meta
`

type CreateURLParams struct {
        ID       string
        UserID   int32
        URL      string
        Filename string
}

func (q *Queries) CreateURL(ctx context.Context, arg CreateURLParams) (URL, error) {
        row := q.db.QueryRowContext(ctx, createURL,
                arg.ID,
                arg.UserID,
                arg.URL,
                arg.Filename,
        )
        var i URL
        err := row.Scan(
                &i.ID,
                &i.UserID,
                &i.URL,
                &i.Filename,
                &i.CreatedAt,
                &i.UpdatedAt,
                &i.Status,
                &i.Size,
                &i.SDHash,
                &i.Meta,
        )
        return i, err
}

const createUpload = `-- name: CreateUpload :one
INSERT INTO uploads (
    id, user_id, size, status, filename, key, sd_hash
) VALUES (
    $1, $2, $3, 'created', '', '', ''
)
RETURNING id, user_id, filename, key, created_at, updated_at, status, size, received, sd_hash, meta
`

type CreateUploadParams struct {
        ID     string
        UserID int32
        Size   int64
}

func (q *Queries) CreateUpload(ctx context.Context, arg CreateUploadParams) (Upload, error) {
        row := q.db.QueryRowContext(ctx, createUpload, arg.ID, arg.UserID, arg.Size)
        var i Upload
        err := row.Scan(
                &i.ID,
                &i.UserID,
                &i.Filename,
                &i.Key,
                &i.CreatedAt,
                &i.UpdatedAt,
                &i.Status,
                &i.Size,
                &i.Received,
                &i.SDHash,
                &i.Meta,
        )
        return i, err
}

const getUpload = `-- name: GetUpload :one
SELECT id, user_id, filename, key, created_at, updated_at, status, size, received, sd_hash, meta FROM uploads
WHERE user_id = $1 AND id = $2
`

type GetUploadParams struct {
        UserID int32
        ID     string
}

func (q *Queries) GetUpload(ctx context.Context, arg GetUploadParams) (Upload, error) {
        row := q.db.QueryRowContext(ctx, getUpload, arg.UserID, arg.ID)
        var i Upload
        err := row.Scan(
                &i.ID,
                &i.UserID,
                &i.Filename,
                &i.Key,
                &i.CreatedAt,
                &i.UpdatedAt,
                &i.Status,
                &i.Size,
                &i.Received,
                &i.SDHash,
                &i.Meta,
        )
        return i, err
}

const markUploadCompleted = `-- name: MarkUploadCompleted :exec
UPDATE uploads SET
    updated_at = NOW(),
    status = 'completed',
    filename = $3,
    key = $4
WHERE user_id = $1 AND id = $2
`

type MarkUploadCompletedParams struct {
        UserID   int32
        ID       string
        Filename string
        Key      string
}

func (q *Queries) MarkUploadCompleted(ctx context.Context, arg MarkUploadCompletedParams) error {
        _, err := q.db.ExecContext(ctx, markUploadCompleted,
                arg.UserID,
                arg.ID,
                arg.Filename,
                arg.Key,
        )
        return err
}

const markUploadProcessed = `-- name: MarkUploadProcessed :exec
UPDATE uploads SET
    updated_at = NOW(),
    status = 'processed',
    sd_hash = $2,
    meta = $3
WHERE id = $1
`

type MarkUploadProcessedParams struct {
        ID     string
        SDHash string
        Meta   pqtype.NullRawMessage
}

func (q *Queries) MarkUploadProcessed(ctx context.Context, arg MarkUploadProcessedParams) error {
        _, err := q.db.ExecContext(ctx, markUploadProcessed, arg.ID, arg.SDHash, arg.Meta)
        return err
}

const markUploadTerminated = `-- name: MarkUploadTerminated :exec
UPDATE uploads SET
    updated_at = NOW(),
    status = 'completed'
WHERE user_id = $1 AND id = $2
`

type MarkUploadTerminatedParams struct {
        UserID int32
        ID     string
}

func (q *Queries) MarkUploadTerminated(ctx context.Context, arg MarkUploadTerminatedParams) error {
        _, err := q.db.ExecContext(ctx, markUploadTerminated, arg.UserID, arg.ID)
        return err
}

const recordUploadProgress = `-- name: RecordUploadProgress :exec
UPDATE uploads SET
    updated_at = NOW(),
    received = $3
WHERE user_id = $1 AND id = $2 AND status IN ('receiving', 'created')
`

type RecordUploadProgressParams struct {
        UserID   int32
        ID       string
        Received int64
}

func (q *Queries) RecordUploadProgress(ctx context.Context, arg RecordUploadProgressParams) error {
        _, err := q.db.ExecContext(ctx, recordUploadProgress, arg.UserID, arg.ID, arg.Received)
        return err
}

1	// Code generated by sqlc. DO NOT EDIT.
2	// versions:
3	// sqlc v1.19.1
4	// source: queries.sql
5
6	package database
7
8	import (
9	"context"
10
11	"github.com/sqlc-dev/pqtype"
12	)
13
14	const createURL = `-- name: CreateURL :one
15	INSERT INTO urls (
16	id, user_id, url, filename, size, sd_hash, status
17	) VALUES (
18	$1, $2, $3, $4, 0, '', 'created'
19	)
20	RETURNING id, user_id, url, filename, created_at, updated_at, status, size, sd_hash, meta
21	`
22
23	type CreateURLParams struct {
24	ID string
25	UserID int32
26	URL string
27	Filename string
28	}
29
30	func (q *Queries) CreateURL(ctx context.Context, arg CreateURLParams) (URL, error) {	×
31	row := q.db.QueryRowContext(ctx, createURL,	×
32	arg.ID,	×
33	arg.UserID,	×
34	arg.URL,	×
35	arg.Filename,	×
36	)	×
37	var i URL	×
38	err := row.Scan(	×
39	&i.ID,	×
40	&i.UserID,	×
41	&i.URL,	×
42	&i.Filename,	×
43	&i.CreatedAt,	×
44	&i.UpdatedAt,	×
45	&i.Status,	×
46	&i.Size,	×
47	&i.SDHash,	×
48	&i.Meta,	×
49	)	×
50	return i, err	×
51	}	×
52
53	const createUpload = `-- name: CreateUpload :one
54	INSERT INTO uploads (
55	id, user_id, size, status, filename, key, sd_hash
56	) VALUES (
57	$1, $2, $3, 'created', '', '', ''
58	)
59	RETURNING id, user_id, filename, key, created_at, updated_at, status, size, received, sd_hash, meta
60	`
61
62	type CreateUploadParams struct {
63	ID string
64	UserID int32
65	Size int64
66	}
67
UNCOV 68	func (q *Queries) CreateUpload(ctx context.Context, arg CreateUploadParams) (Upload, error) {	×
UNCOV 69	row := q.db.QueryRowContext(ctx, createUpload, arg.ID, arg.UserID, arg.Size)	×
UNCOV 70	var i Upload	×
UNCOV 71	err := row.Scan(	×
UNCOV 72	&i.ID,	×
UNCOV 73	&i.UserID,	×
UNCOV 74	&i.Filename,	×
UNCOV 75	&i.Key,	×
UNCOV 76	&i.CreatedAt,	×
UNCOV 77	&i.UpdatedAt,	×
UNCOV 78	&i.Status,	×
UNCOV 79	&i.Size,	×
UNCOV 80	&i.Received,	×
UNCOV 81	&i.SDHash,	×
UNCOV 82	&i.Meta,	×
UNCOV 83	)	×
UNCOV 84	return i, err	×
UNCOV 85	}	×
86
87	const getUpload = `-- name: GetUpload :one
88	SELECT id, user_id, filename, key, created_at, updated_at, status, size, received, sd_hash, meta FROM uploads
89	WHERE user_id = $1 AND id = $2
90	`
91
92	type GetUploadParams struct {
93	UserID int32
94	ID string
95	}
96
UNCOV 97	func (q *Queries) GetUpload(ctx context.Context, arg GetUploadParams) (Upload, error) {	×
UNCOV 98	row := q.db.QueryRowContext(ctx, getUpload, arg.UserID, arg.ID)	×
UNCOV 99	var i Upload	×
UNCOV 100	err := row.Scan(	×
UNCOV 101	&i.ID,	×
UNCOV 102	&i.UserID,	×
UNCOV 103	&i.Filename,	×
UNCOV 104	&i.Key,	×
UNCOV 105	&i.CreatedAt,	×
UNCOV 106	&i.UpdatedAt,	×
UNCOV 107	&i.Status,	×
UNCOV 108	&i.Size,	×
UNCOV 109	&i.Received,	×
UNCOV 110	&i.SDHash,	×
UNCOV 111	&i.Meta,	×
UNCOV 112	)	×
UNCOV 113	return i, err	×
UNCOV 114	}	×
115
116	const markUploadCompleted = `-- name: MarkUploadCompleted :exec
117	UPDATE uploads SET
118	updated_at = NOW(),
119	status = 'completed',
120	filename = $3,
121	key = $4
122	WHERE user_id = $1 AND id = $2
123	`
124
125	type MarkUploadCompletedParams struct {
126	UserID int32
127	ID string
128	Filename string
129	Key string
130	}
131
UNCOV 132	func (q *Queries) MarkUploadCompleted(ctx context.Context, arg MarkUploadCompletedParams) error {	×
UNCOV 133	_, err := q.db.ExecContext(ctx, markUploadCompleted,	×
UNCOV 134	arg.UserID,	×
UNCOV 135	arg.ID,	×
UNCOV 136	arg.Filename,	×
UNCOV 137	arg.Key,	×
UNCOV 138	)	×
UNCOV 139	return err	×
UNCOV 140	}	×
141
142	const markUploadProcessed = `-- name: MarkUploadProcessed :exec
143	UPDATE uploads SET
144	updated_at = NOW(),
145	status = 'processed',
146	sd_hash = $2,
147	meta = $3
148	WHERE id = $1
149	`
150
151	type MarkUploadProcessedParams struct {
152	ID string
153	SDHash string
154	Meta pqtype.NullRawMessage
155	}
156
157	func (q *Queries) MarkUploadProcessed(ctx context.Context, arg MarkUploadProcessedParams) error {	×
158	_, err := q.db.ExecContext(ctx, markUploadProcessed, arg.ID, arg.SDHash, arg.Meta)	×
159	return err	×
160	}	×
161
162	const markUploadTerminated = `-- name: MarkUploadTerminated :exec
163	UPDATE uploads SET
164	updated_at = NOW(),
165	status = 'completed'
166	WHERE user_id = $1 AND id = $2
167	`
168
169	type MarkUploadTerminatedParams struct {
170	UserID int32
171	ID string
172	}
173
174	func (q *Queries) MarkUploadTerminated(ctx context.Context, arg MarkUploadTerminatedParams) error {	×
175	_, err := q.db.ExecContext(ctx, markUploadTerminated, arg.UserID, arg.ID)	×
176	return err	×
177	}	×
178
179	const recordUploadProgress = `-- name: RecordUploadProgress :exec
180	UPDATE uploads SET
181	updated_at = NOW(),
182	received = $3
183	WHERE user_id = $1 AND id = $2 AND status IN ('receiving', 'created')
184	`
185
186	type RecordUploadProgressParams struct {
187	UserID int32
188	ID string
189	Received int64
190	}
191
UNCOV 192	func (q *Queries) RecordUploadProgress(ctx context.Context, arg RecordUploadProgressParams) error {	×
UNCOV 193	_, err := q.db.ExecContext(ctx, recordUploadProgress, arg.UserID, arg.ID, arg.Received)	×
UNCOV 194	return err	×
UNCOV 195	}	×

OdyseeTeam / odysee-api / 14728457306

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous