owncast/db/query.sql.go
2022-01-24 15:39:32 -08:00

441 lines
11 KiB
Go

// Code generated by sqlc. DO NOT EDIT.
// source: query.sql
package db
import (
"context"
"database/sql"
"time"
)
const addFollower = `-- name: AddFollower :exec
INSERT INTO ap_followers(iri, inbox, request, name, username, image, approved_at) values($1, $2, $3, $4, $5, $6, $7)
`
type AddFollowerParams struct {
Iri string
Inbox string
Request string
Name sql.NullString
Username string
Image sql.NullString
ApprovedAt sql.NullTime
}
func (q *Queries) AddFollower(ctx context.Context, arg AddFollowerParams) error {
_, err := q.db.ExecContext(ctx, addFollower,
arg.Iri,
arg.Inbox,
arg.Request,
arg.Name,
arg.Username,
arg.Image,
arg.ApprovedAt,
)
return err
}
const addToAcceptedActivities = `-- name: AddToAcceptedActivities :exec
INSERT INTO ap_accepted_activities(iri, actor, type, timestamp) values($1, $2, $3, $4)
`
type AddToAcceptedActivitiesParams struct {
Iri string
Actor string
Type string
Timestamp time.Time
}
func (q *Queries) AddToAcceptedActivities(ctx context.Context, arg AddToAcceptedActivitiesParams) error {
_, err := q.db.ExecContext(ctx, addToAcceptedActivities,
arg.Iri,
arg.Actor,
arg.Type,
arg.Timestamp,
)
return err
}
const addToOutbox = `-- name: AddToOutbox :exec
INSERT INTO ap_outbox(iri, value, type, live_notification) values($1, $2, $3, $4)
`
type AddToOutboxParams struct {
Iri string
Value []byte
Type string
LiveNotification sql.NullBool
}
func (q *Queries) AddToOutbox(ctx context.Context, arg AddToOutboxParams) error {
_, err := q.db.ExecContext(ctx, addToOutbox,
arg.Iri,
arg.Value,
arg.Type,
arg.LiveNotification,
)
return err
}
const approveFederationFollower = `-- name: ApproveFederationFollower :exec
UPDATE ap_followers SET approved_at = $1, disabled_at = null WHERE iri = $2
`
type ApproveFederationFollowerParams struct {
ApprovedAt sql.NullTime
Iri string
}
func (q *Queries) ApproveFederationFollower(ctx context.Context, arg ApproveFederationFollowerParams) error {
_, err := q.db.ExecContext(ctx, approveFederationFollower, arg.ApprovedAt, arg.Iri)
return err
}
const doesInboundActivityExist = `-- name: DoesInboundActivityExist :one
SELECT count(*) FROM ap_accepted_activities WHERE iri = $1 AND actor = $2 AND TYPE = $3
`
type DoesInboundActivityExistParams struct {
Iri string
Actor string
Type string
}
func (q *Queries) DoesInboundActivityExist(ctx context.Context, arg DoesInboundActivityExistParams) (int64, error) {
row := q.db.QueryRowContext(ctx, doesInboundActivityExist, arg.Iri, arg.Actor, arg.Type)
var count int64
err := row.Scan(&count)
return count, err
}
const getFederationFollowerApprovalRequests = `-- name: GetFederationFollowerApprovalRequests :many
SELECT iri, inbox, name, username, image, created_at FROM ap_followers WHERE approved_at IS null AND disabled_at is null
`
type GetFederationFollowerApprovalRequestsRow struct {
Iri string
Inbox string
Name sql.NullString
Username string
Image sql.NullString
CreatedAt sql.NullTime
}
func (q *Queries) GetFederationFollowerApprovalRequests(ctx context.Context) ([]GetFederationFollowerApprovalRequestsRow, error) {
rows, err := q.db.QueryContext(ctx, getFederationFollowerApprovalRequests)
if err != nil {
return nil, err
}
defer rows.Close()
var items []GetFederationFollowerApprovalRequestsRow
for rows.Next() {
var i GetFederationFollowerApprovalRequestsRow
if err := rows.Scan(
&i.Iri,
&i.Inbox,
&i.Name,
&i.Username,
&i.Image,
&i.CreatedAt,
); err != nil {
return nil, err
}
items = append(items, i)
}
if err := rows.Close(); err != nil {
return nil, err
}
if err := rows.Err(); err != nil {
return nil, err
}
return items, nil
}
const getFederationFollowersWithOffset = `-- name: GetFederationFollowersWithOffset :many
SELECT iri, inbox, name, username, image, created_at FROM ap_followers WHERE approved_at is not null ORDER BY created_at DESC LIMIT $1 OFFSET $2
`
type GetFederationFollowersWithOffsetParams struct {
Limit int32
Offset int32
}
type GetFederationFollowersWithOffsetRow struct {
Iri string
Inbox string
Name sql.NullString
Username string
Image sql.NullString
CreatedAt sql.NullTime
}
func (q *Queries) GetFederationFollowersWithOffset(ctx context.Context, arg GetFederationFollowersWithOffsetParams) ([]GetFederationFollowersWithOffsetRow, error) {
rows, err := q.db.QueryContext(ctx, getFederationFollowersWithOffset, arg.Limit, arg.Offset)
if err != nil {
return nil, err
}
defer rows.Close()
var items []GetFederationFollowersWithOffsetRow
for rows.Next() {
var i GetFederationFollowersWithOffsetRow
if err := rows.Scan(
&i.Iri,
&i.Inbox,
&i.Name,
&i.Username,
&i.Image,
&i.CreatedAt,
); err != nil {
return nil, err
}
items = append(items, i)
}
if err := rows.Close(); err != nil {
return nil, err
}
if err := rows.Err(); err != nil {
return nil, err
}
return items, nil
}
const getFollowerByIRI = `-- name: GetFollowerByIRI :one
SELECT iri, inbox, name, username, image, request, created_at, approved_at, disabled_at FROM ap_followers WHERE iri = $1
`
func (q *Queries) GetFollowerByIRI(ctx context.Context, iri string) (ApFollower, error) {
row := q.db.QueryRowContext(ctx, getFollowerByIRI, iri)
var i ApFollower
err := row.Scan(
&i.Iri,
&i.Inbox,
&i.Name,
&i.Username,
&i.Image,
&i.Request,
&i.CreatedAt,
&i.ApprovedAt,
&i.DisabledAt,
)
return i, err
}
const getFollowerCount = `-- name: GetFollowerCount :one
SElECT count(*) FROM ap_followers WHERE approved_at is not null
`
// Queries added to query.sql must be compiled into Go code with sqlc. Read README.md for details.
// Federation related queries.
func (q *Queries) GetFollowerCount(ctx context.Context) (int64, error) {
row := q.db.QueryRowContext(ctx, getFollowerCount)
var count int64
err := row.Scan(&count)
return count, err
}
const getInboundActivitiesWithOffset = `-- name: GetInboundActivitiesWithOffset :many
SELECT iri, actor, type, timestamp FROM ap_accepted_activities ORDER BY timestamp DESC LIMIT $1 OFFSET $2
`
type GetInboundActivitiesWithOffsetParams struct {
Limit int32
Offset int32
}
type GetInboundActivitiesWithOffsetRow struct {
Iri string
Actor string
Type string
Timestamp time.Time
}
func (q *Queries) GetInboundActivitiesWithOffset(ctx context.Context, arg GetInboundActivitiesWithOffsetParams) ([]GetInboundActivitiesWithOffsetRow, error) {
rows, err := q.db.QueryContext(ctx, getInboundActivitiesWithOffset, arg.Limit, arg.Offset)
if err != nil {
return nil, err
}
defer rows.Close()
var items []GetInboundActivitiesWithOffsetRow
for rows.Next() {
var i GetInboundActivitiesWithOffsetRow
if err := rows.Scan(
&i.Iri,
&i.Actor,
&i.Type,
&i.Timestamp,
); err != nil {
return nil, err
}
items = append(items, i)
}
if err := rows.Close(); err != nil {
return nil, err
}
if err := rows.Err(); err != nil {
return nil, err
}
return items, nil
}
const getLocalPostCount = `-- name: GetLocalPostCount :one
SElECT count(*) FROM ap_outbox
`
func (q *Queries) GetLocalPostCount(ctx context.Context) (int64, error) {
row := q.db.QueryRowContext(ctx, getLocalPostCount)
var count int64
err := row.Scan(&count)
return count, err
}
const getObjectFromOutboxByID = `-- name: GetObjectFromOutboxByID :one
SELECT value FROM ap_outbox WHERE iri = $1
`
func (q *Queries) GetObjectFromOutboxByID(ctx context.Context, iri string) ([]byte, error) {
row := q.db.QueryRowContext(ctx, getObjectFromOutboxByID, iri)
var value []byte
err := row.Scan(&value)
return value, err
}
const getObjectFromOutboxByIRI = `-- name: GetObjectFromOutboxByIRI :one
SELECT value, live_notification, created_at FROM ap_outbox WHERE iri = $1
`
type GetObjectFromOutboxByIRIRow struct {
Value []byte
LiveNotification sql.NullBool
CreatedAt sql.NullTime
}
func (q *Queries) GetObjectFromOutboxByIRI(ctx context.Context, iri string) (GetObjectFromOutboxByIRIRow, error) {
row := q.db.QueryRowContext(ctx, getObjectFromOutboxByIRI, iri)
var i GetObjectFromOutboxByIRIRow
err := row.Scan(&i.Value, &i.LiveNotification, &i.CreatedAt)
return i, err
}
const getOutboxWithOffset = `-- name: GetOutboxWithOffset :many
SELECT value FROM ap_outbox LIMIT $1 OFFSET $2
`
type GetOutboxWithOffsetParams struct {
Limit int32
Offset int32
}
func (q *Queries) GetOutboxWithOffset(ctx context.Context, arg GetOutboxWithOffsetParams) ([][]byte, error) {
rows, err := q.db.QueryContext(ctx, getOutboxWithOffset, arg.Limit, arg.Offset)
if err != nil {
return nil, err
}
defer rows.Close()
var items [][]byte
for rows.Next() {
var value []byte
if err := rows.Scan(&value); err != nil {
return nil, err
}
items = append(items, value)
}
if err := rows.Close(); err != nil {
return nil, err
}
if err := rows.Err(); err != nil {
return nil, err
}
return items, nil
}
const getRejectedAndBlockedFollowers = `-- name: GetRejectedAndBlockedFollowers :many
SELECT iri, name, username, image, created_at, disabled_at FROM ap_followers WHERE disabled_at is not null
`
type GetRejectedAndBlockedFollowersRow struct {
Iri string
Name sql.NullString
Username string
Image sql.NullString
CreatedAt sql.NullTime
DisabledAt sql.NullTime
}
func (q *Queries) GetRejectedAndBlockedFollowers(ctx context.Context) ([]GetRejectedAndBlockedFollowersRow, error) {
rows, err := q.db.QueryContext(ctx, getRejectedAndBlockedFollowers)
if err != nil {
return nil, err
}
defer rows.Close()
var items []GetRejectedAndBlockedFollowersRow
for rows.Next() {
var i GetRejectedAndBlockedFollowersRow
if err := rows.Scan(
&i.Iri,
&i.Name,
&i.Username,
&i.Image,
&i.CreatedAt,
&i.DisabledAt,
); err != nil {
return nil, err
}
items = append(items, i)
}
if err := rows.Close(); err != nil {
return nil, err
}
if err := rows.Err(); err != nil {
return nil, err
}
return items, nil
}
const rejectFederationFollower = `-- name: RejectFederationFollower :exec
UPDATE ap_followers SET approved_at = null, disabled_at = $1 WHERE iri = $2
`
type RejectFederationFollowerParams struct {
DisabledAt sql.NullTime
Iri string
}
func (q *Queries) RejectFederationFollower(ctx context.Context, arg RejectFederationFollowerParams) error {
_, err := q.db.ExecContext(ctx, rejectFederationFollower, arg.DisabledAt, arg.Iri)
return err
}
const removeFollowerByIRI = `-- name: RemoveFollowerByIRI :exec
DELETE FROM ap_followers WHERE iri = $1
`
func (q *Queries) RemoveFollowerByIRI(ctx context.Context, iri string) error {
_, err := q.db.ExecContext(ctx, removeFollowerByIRI, iri)
return err
}
const updateFollowerByIRI = `-- name: UpdateFollowerByIRI :exec
UPDATE ap_followers SET inbox = $1, name = $2, username = $3, image = $4 WHERE iri = $5
`
type UpdateFollowerByIRIParams struct {
Inbox string
Name sql.NullString
Username string
Image sql.NullString
Iri string
}
func (q *Queries) UpdateFollowerByIRI(ctx context.Context, arg UpdateFollowerByIRIParams) error {
_, err := q.db.ExecContext(ctx, updateFollowerByIRI,
arg.Inbox,
arg.Name,
arg.Username,
arg.Image,
arg.Iri,
)
return err
}