got inital sqlite working

Author: Klaven

.gitignore

@@ -18,3 +18,7 @@ Cargo.lock
 
 # rust
 **/target/*
+
+# sqlite
+*.db-shm
+*.db-wal

cri/build.rs

@@ -6,6 +6,5 @@ fn main() -> Result<(), Box<dyn std::error::Error>> {
         .build_server(true)
         .compile(PROTO_FILES, &["vendor/"])
         .expect("Failed to generate GRPC bindings");
-
     Ok(())
 }

server/.env

@@ -1 +1 @@
-DATABASE_URL='sqlite://al.db' # Or path to database file if using sqlite3.
+DATABASE_URL='sqlite:server/al.db' # Or path to database file if using sqlite3.

server/al.db

@@ -0,0 +1,10 @@
+CREATE TABLE IF NOT EXISTS repositories (
+    id          INTEGER PRIMARY KEY NOT NULL,
+    name        TEXT                NOT NULL,
+    description TEXT                NOT NULL,
+    url         TEXT                NOT NULL,
+    created_at  TEXT                NOT NULL,
+    updated_at  TEXT                NOT NULL,
+    pushed_at   TEXT                NOT NULL,
+    pipelines   TEXT                NOT NULL,
+);

server/migrations/20230228224430.sql

@@ -1,17 +1,13 @@
-use sqlx::any::AnyPool;
-use sqlx::database::Database;
-use sqlx::error::Error;
-use sqlx::pool::PoolConnection;
-use sqlx::postgres::PgPool;
-use sqlx::sqlite::{SqliteConnectOptions, SqlitePool};
+use sqlx::sqlite::{ SqlitePool};
+
 
 pub struct ConnectionManager {
-    pool: AnyPool,
+    pub pool: SqlitePool,
 }
 
 impl ConnectionManager {
     pub async fn new(url: String) -> anyhow::Result<Self> {
-        let pool = AnyPool::connect(&url).await?;
+        let pool = SqlitePool::connect(&url).await?;
         Ok(Self { pool })
     }
 }

server/src/database/connection_manager.rs

@@ -1,13 +1,31 @@
 mod config;
 mod database;
-use actix_web::{get, post, web, App, HttpResponse, HttpServer, Responder};
+use actix_web::{get, post, App, HttpResponse, HttpServer, Responder};
 use database::connection_manager::ConnectionManager;
+use std::env;
 
 #[tokio::main]
-async fn main() -> std::io::Result<()> {
+async fn main() -> anyhow::Result<()> {
     // Get the server config
 
     // Get the database connection manager
+    //let con_man = ConnectionManager::new(env::var("DATABASE_URL")?).await?;
+
+    let con_man = ConnectionManager::new(env::var("DATABASE_URL")?).await?;
+
+    let mut con = con_man.pool.acquire().await?;
+
+    let id = sqlx::query!(
+        r#"
+        CREATE TABLE IF NOT EXISTS repositories (
+            id INTEGER PRIMARY KEY,
+            description TEXT NOT NULL
+        )
+        "#,
+    )
+    .execute(&mut con)
+    .await?
+    .last_insert_rowid();
 
     // start listening to github webhook
 
@@ -16,6 +34,7 @@ async fn main() -> std::io::Result<()> {
         .bind(("127.0.0.1", 8080))?
         .run()
         .await
+        .map_err(|e| e.into())
 }
 
 #[get("/agent/{id}")]