From c62478603c96d8ba46c28d9c841df5dc0eb16a2c Mon Sep 17 00:00:00 2001
From: oupson <oupson1er@gmail.com>
Date: Sat, 8 Jan 2022 15:58:10 +0100
Subject: [PATCH] Add table creation

---
 .gitignore     |  4 +++-
 src/main.zig   | 63 +++++++++++++++++++++++++++++++++++++++++++++++++-
 src/sqlite.zig |  2 +-
 3 files changed, 66 insertions(+), 3 deletions(-)

diff --git a/.gitignore b/.gitignore
index 94bcab0..02a2977 100644
--- a/.gitignore
+++ b/.gitignore
@@ -1,3 +1,5 @@
 zig-cache
 zig-out
-config.json
\ No newline at end of file
+
+config.json
+*.db
\ No newline at end of file
diff --git a/src/main.zig b/src/main.zig
index 4076e8e..b0ff0db 100644
--- a/src/main.zig
+++ b/src/main.zig
@@ -6,6 +6,65 @@ const Client = @import("client.zig").Client;
 const webhook = @import("webhook.zig");
 const sqlite = @import("sqlite.zig");
 
+const CREATE_TABLES =
+    \\ CREATE TABLE VERSION
+    \\ (
+    \\     versionCode INTEGER
+    \\ );
+    \\ 
+    \\ INSERT INTO VERSION(versionCode)
+    \\ VALUES (1);
+    \\ 
+    \\ CREATE TABLE STREAMER
+    \\ (
+    \\     idStreamer    TEXT PRIMARY KEY NOT NULL,
+    \\     loginStreamer TEXT             NOT NULL,
+    \\     nameStreamer  TEXT             NOT NULL
+    \\ );
+    \\ 
+    \\ CREATE TABLE STREAM
+    \\ (
+    \\     idStream       TEXT PRIMARY KEY NOT NULL,
+    \\     idStreamer     TEXT             NOT NULL,
+    \\     isMatureStream BOOLEAN          NOT NULL DEFAULT 'F',
+    \\     CONSTRAINT FK_STREAM_STREAMER_ID FOREIGN KEY (idStreamer) REFERENCES STREAMER (idStreamer)
+    \\ );
+    \\ 
+    \\ CREATE TABLE VIEWER_COUNT_STREAM
+    \\ (
+    \\     viewerCount     INTEGER NOT NULL,
+    \\     dateViewerCount DATE    NOT NULL,
+    \\     idStream        TEXT    NOT NULL,
+    \\     PRIMARY KEY (dateViewerCount, idStream),
+    \\     CONSTRAINT FK_VIEWER_COUNT_STREAM_ID FOREIGN KEY (idStream) REFERENCES STREAM (idStream)
+    \\ );
+    \\ 
+    \\ CREATE TABLE NAME_STREAM
+    \\ (
+    \\     nameStream     TEXT NOT NULL,
+    \\     dateNameStream DATE NOT NULL,
+    \\     idStream       TEXT NOT NULL,
+    \\     PRIMARY KEY (dateNameStream, idStream),
+    \\     CONSTRAINT FK_NAME_STREAM_STREAM_ID FOREIGN KEY (idStream) REFERENCES STREAM (idStream)
+    \\ );
+    \\ 
+    \\ CREATE TABLE GAME
+    \\ (
+    \\     gameId   TEXT NOT NULL PRIMARY KEY,
+    \\     gameName TEXT
+    \\ );
+    \\ 
+    \\ CREATE TABLE IS_STREAMING_GAME
+    \\ (
+    \\     gameId         TEXT NOT NULL,
+    \\     streamId       TEXT NOT NULL,
+    \\     dateGameStream DATE NOT NULL,
+    \\     PRIMARY KEY (gameId, streamId, dateGameStream),
+    \\     CONSTRAINT FK_GAME_STREAM_GAME_ID FOREIGN KEY (gameId) REFERENCES GAME (gameId),
+    \\     CONSTRAINT FK_GAME_STREAM_STREAM_ID FOREIGN KEY (streamId) REFERENCES STREAM (idStream)
+    \\ );
+;
+
 const Config = struct {
     token: []const u8,
     client_id: []const u8,
@@ -34,13 +93,15 @@ const User = struct {
 };
 
 pub fn main() anyerror!void {
-    var db = try sqlite.Database.open("a.db");
+    var db = try sqlite.Database.open("data.db");
     defer {
         _ = db.close() catch |e| {
             std.log.err("Failed to close db : {}", .{e});
         };
     }
 
+    try db.exec(CREATE_TABLES);
+
     var arena = std.heap.ArenaAllocator.init(std.heap.page_allocator);
     var allocator = arena.allocator();
 
diff --git a/src/sqlite.zig b/src/sqlite.zig
index efba58f..5a31c27 100644
--- a/src/sqlite.zig
+++ b/src/sqlite.zig
@@ -168,7 +168,7 @@ pub const Statement = struct {
                                             var blob = @ptrCast([*]const u8, blob_ptr);
                                             var size = sqlite3.sqlite3_column_bytes(self.statement, @intCast(c_int, index));
 
-                                            arg.bytes = blob[0..@intCast(usize, size)]; // TODO TEST
+                                            arg.bytes = blob[0..@intCast(usize, size)];
                                         }
                                     },
                                 }