feat: Create audio/video profiles

internal/db/store.go

@@ -10,4 +10,6 @@ type InputStore interface {
 	CreateInput(context.Context, CreateInputParams) (Input, error)
 	GetInput(context.Context, uuid.UUID) (Input, error)
 	DeleteInput(context.Context, uuid.UUID) error
+	CreateAudioProfile(context.Context, CreateAudioProfileParams) error
+	CreateVideoProfile(context.Context, CreateVideoProfileParams) error
 }

internal/model/input.go

@@ -3,7 +3,23 @@ package model
 import "github.com/google/uuid"
 
 type Input struct {
-	ID     uuid.UUID `json:"id"`
-	Name   string    `json:"name" validate:"required"`
-	Format string    `json:"format" validate:"required"`
+	ID     uuid.UUID      `json:"id"`
+	Name   string         `json:"name" validate:"required"`
+	Format string         `json:"format" validate:"required"`
+	Audio  []AudioProfile `json:"audio"`
+	Video  []VideoProfile `json:"video"`
+}
+
+type AudioProfile struct {
+	Rate  int    `json:"rate"`
+	Codec string `json:"codec"`
+}
+
+type VideoProfile struct {
+	Codec          string `json:"codec"`
+	Bitrate        int    `json:"bitrate"`
+	MaxKeyInterval int    `json:"max_key_interval"`
+	Framerate      int    `json:"framerate"`
+	Width          int    `json:"width"`
+	Height         int    `json:"height"`
 }

internal/service/input.go

@@ -4,6 +4,7 @@ import (
 	"context"
 
 	"github.com/google/uuid"
+	"github.com/jackc/pgx/v5/pgtype"
 	"github.com/learn-video/dionysia/internal/db"
 	"github.com/learn-video/dionysia/internal/model"
 )
@@ -35,6 +36,34 @@ func (handler *inputHandler) CreateInput(ctx context.Context, in *model.Input) (
 		return model.Input{}, err
 	}
 
+	for _, a := range in.Audio {
+		err := handler.store.CreateAudioProfile(ctx, db.CreateAudioProfileParams{
+			InputID: input.ID,
+			Rate:    pgtype.Int4{Int32: int32(a.Rate), Valid: true},
+			Codec:   a.Codec,
+		})
+
+		if err != nil {
+			return model.Input{}, err
+		}
+	}
+
+	for _, v := range in.Video {
+		err := handler.store.CreateVideoProfile(ctx, db.CreateVideoProfileParams{
+			InputID:        input.ID,
+			Width:          pgtype.Int4{Int32: int32(v.Width), Valid: true},
+			Height:         pgtype.Int4{Int32: int32(v.Height), Valid: true},
+			Codec:          v.Codec,
+			MaxKeyInterval: pgtype.Int4{Int32: int32(v.MaxKeyInterval), Valid: true},
+			Framerate:      pgtype.Int4{Int32: int32(v.Framerate), Valid: true},
+			Bitrate:        pgtype.Int4{Int32: int32(v.Bitrate), Valid: true},
+		})
+
+		if err != nil {
+			return model.Input{}, err
+		}
+	}
+
 	return model.Input{
 		ID:     input.ID,
 		Name:   input.Name,

query.sql

@@ -6,3 +6,23 @@ SELECT * FROM inputs WHERE id = $1;
 
 -- name: DeleteInput :exec
 DELETE FROM inputs WHERE id = $1;
+
+-- name: CreateVideoProfile :exec
+INSERT INTO video_profiles (input_id, codec, bitrate, max_key_interval, framerate, width, height)
+VALUES ($1, $2, $3, $4, $5, $6, $7);
+
+-- name: GetVideoProfiles :many
+SELECT * FROM video_profiles WHERE input_id = $1;
+
+-- name: DeleteVideoProfiles :exec
+DELETE FROM video_profiles WHERE input_id = $1;
+
+-- name: CreateAudioProfile :exec
+INSERT INTO audio_profiles (input_id, rate, codec)
+VALUES ($1, $2, $3);
+
+-- name: GetAudioProfiles :many
+SELECT * FROM audio_profiles WHERE input_id = $1;
+
+-- name: DeleteAudioProfiles :exec
+DELETE FROM audio_profiles WHERE input_id = $1;

schema.sql

@@ -1,5 +1,25 @@
 CREATE TABLE inputs (
-    id uuid PRIMARY KEY,
-    name text NOT NULL,
-    format text NOT NULL
+    id UUID PRIMARY KEY,
+    name TEXT NOT NULL,
+    format TEXT NOT NULL
+);
+
+CREATE TABLE audio_profiles (
+    id SERIAL PRIMARY KEY,
+    input_id UUID NOT NULL,
+    rate INT,
+    codec TEXT NOT NULL,
+    FOREIGN KEY (input_id) REFERENCES inputs(id)
+);
+
+CREATE TABLE video_profiles (
+    id SERIAL PRIMARY KEY,
+    input_id UUID NOT NULL,
+    codec TEXT NOT NULL,
+    bitrate INT,
+    max_key_interval INT,
+    framerate INT,
+    width INT,
+    height INT,
+    FOREIGN KEY (input_id) REFERENCES inputs(id)
 );