From 2c052ea29207fea38ecce9afeb38a824e79cf4ea Mon Sep 17 00:00:00 2001
From: Neil Alexander <neilalexander@users.noreply.github.com>
Date: Tue, 11 Oct 2022 15:14:25 +0100
Subject: [PATCH] Provide stream ID statements

---
 syncapi/storage/sqlite3/relations_table.go | 6 ++++--
 syncapi/storage/sqlite3/syncserver.go      | 2 +-
 2 files changed, 5 insertions(+), 3 deletions(-)

diff --git a/syncapi/storage/sqlite3/relations_table.go b/syncapi/storage/sqlite3/relations_table.go
index 03f9d5123..991f7e471 100644
--- a/syncapi/storage/sqlite3/relations_table.go
+++ b/syncapi/storage/sqlite3/relations_table.go
@@ -68,8 +68,10 @@ type relationsStatements struct {
 	selectMaxRelationIDStmt          *sql.Stmt
 }
 
-func NewSqliteRelationsTable(db *sql.DB) (tables.Relations, error) {
-	s := &relationsStatements{}
+func NewSqliteRelationsTable(db *sql.DB, streamID *StreamIDStatements) (tables.Relations, error) {
+	s := &relationsStatements{
+		streamIDStatements: streamID,
+	}
 	_, err := db.Exec(relationsSchema)
 	if err != nil {
 		return nil, err
diff --git a/syncapi/storage/sqlite3/syncserver.go b/syncapi/storage/sqlite3/syncserver.go
index 7ff935b65..510546909 100644
--- a/syncapi/storage/sqlite3/syncserver.go
+++ b/syncapi/storage/sqlite3/syncserver.go
@@ -123,7 +123,7 @@ func (d *SyncServerDatasource) prepare(ctx context.Context) (err error) {
 	if err != nil {
 		return err
 	}
-	relations, err := NewSqliteRelationsTable(d.db)
+	relations, err := NewSqliteRelationsTable(d.db, &d.streamID)
 	if err != nil {
 		return err
 	}