about summary refs log tree commit diff
path: root/src/payload-processor/processor/db.go
diff options
context:
space:
mode:
Diffstat (limited to 'src/payload-processor/processor/db.go')
-rw-r--r--src/payload-processor/processor/db.go7
1 files changed, 3 insertions, 4 deletions
diff --git a/src/payload-processor/processor/db.go b/src/payload-processor/processor/db.go
index bad31d1..ce7d5bb 100644
--- a/src/payload-processor/processor/db.go
+++ b/src/payload-processor/processor/db.go
@@ -2,14 +2,13 @@ package processor
 
 import (
 	"context"
-	"time"
 
 	"github.com/jmoiron/sqlx"
 )
 
 //go:generate mockgen -source=$GOFILE -package=$GOPACKAGE -destination=mock_$GOFILE
 type DB interface {
-	TestInsert(ctx context.Context, message string) error
+	InsertFile(ctx context.Context, file File) error
 }
 
 type DBImpl struct {
@@ -22,7 +21,7 @@ func NewDB(db *sqlx.DB) DB {
 	return &DBImpl{db: db}
 }
 
-func (db DBImpl) TestInsert(ctx context.Context, message string) error {
-	_, err := db.db.ExecContext(ctx, "INSERT INTO test (created_at, test) VALUES ($1, $2)", time.Now(), message)
+func (db DBImpl) InsertFile(ctx context.Context, file File) error {
+	_, err := db.db.NamedExecContext(ctx, "INSERT INTO private.file (user_id, absolute_path, contents, timestamp) VALUES (:user_id, :absolute_path, :contents, :timestamp)", file)
 	return err
 }