Development

.github/workflows/checkout.yaml

@@ -0,0 +1,50 @@
+on:
+  push:
+    branches:
+      - development
+
+env:
+  IMAGE_NAME: sigmaproductions/sigmachatserver
+
+jobs:
+  build:
+    runs-on: [self-hosted, build]
+    steps:
+    - name: Set build tag
+      run: |
+        echo "IMAGE_TAG=$(git rev-parse --short HEAD)" >> "$GITHUB_ENV"
+    - name: Checkout repository
+      uses: actions/checkout@v2
+    - name: Configure appsettings.json
+      env:
+        appsettings: ${{ secrets.appsettings }}
+      run: |
+        echo "$appsettings" > appsettings.json
+    - name: Login to Docker Hub
+      uses: docker/login-action@v3
+      with:
+        username: ${{ secrets.DOCKERHUB_USERNAME }}
+        password: ${{ secrets.DOCKERHUB_TOKEN }}
+    - name: Build the Docker image
+      run: docker build . --file Dockerfile --tag ${IMAGE_NAME}:${IMAGE_TAG}
+    - name: Publish the Docker image
+      run: docker push ${IMAGE_NAME}:${IMAGE_TAG}
+  deploy:
+    needs: build
+    runs-on: [self-hosted, deploy]
+    steps:
+    - name: Set build tag
+      run: |
+        echo "IMAGE_TAG=$(git rev-parse --short HEAD)" >> "$GITHUB_ENV"
+    - name: Checkout repository
+      uses: actions/checkout@v2
+    - name: Login to Docker Hub
+      uses: docker/login-action@v3
+      with:
+        username: ${{ secrets.DOCKERHUB_USERNAME }}
+        password: ${{ secrets.DOCKERHUB_TOKEN }}
+    - name: Pull and deploy
+      env:
+        AZURITE_ACCOUNTS: ${{ secrets.azurite_accounts }}
+      run: docker-compose -f compose.prod.yaml pull &&
+           docker-compose -f compose.prod.yaml up -d

.gitignore

@@ -253,3 +253,5 @@ paket-files/
 # JetBrains Rider
 .idea/
 *.sln.iml
+
+appsettings.json

.vscode/launch.json

@@ -0,0 +1,30 @@
+{
+  // Use IntelliSense to learn about possible attributes.
+  // Hover to view descriptions of existing attributes.
+  // For more information, visit: https://go.microsoft.com/fwlink/?linkid=830387
+  "version": "0.2.0",
+  "configurations": [
+    {
+      "name": ".NET Core Launch (console)",
+      "type": "coreclr",
+      "request": "launch",
+      "preLaunchTask": "Build: SigmaChatServer.fsproj",
+      "program": "${workspaceFolder}/bin/Debug/net7.0/SigmaChatServer.App.dll",
+      "args": [],
+      "cwd": "${workspaceFolder}",
+      "stopAtEntry": false,
+      "console": "internalConsole"
+    },
+    {
+      "name": "F#: <project-name> Debug",
+      "type": "dotnet",
+      "request": "launch",
+      "projectPath": "${workspaceFolder}/SigmaChatServer.fsproj"
+    },
+    {
+      "name": ".NET Core Attach",
+      "type": "coreclr",
+      "request": "attach"
+    }
+  ]
+}

.vscode/tasks.json

@@ -0,0 +1,12 @@
+{
+  "version": "2.0.0",
+  "tasks": [
+    {
+      "type": "msbuild",
+      "problemMatcher": ["$msCompile"],
+      "group": "build",
+      "label": "Build: SigmaChatServer.fsproj",
+      "detail": "Build the SigmaChatServer.fsproj project using dotnet build"
+    }
+  ]
+}

BlobHandlers.fs

@@ -0,0 +1,90 @@
+namespace SigmaChatServer
+
+module BlobHandlers =
+
+    open Microsoft.AspNetCore.Http
+    open Giraffe
+    open System.Data
+    open SigmaChatServer.Models
+    open Npgsql
+    open Azure.Storage.Blobs
+    open System
+    open Giraffe.HttpStatusCodeHandlers.RequestErrors
+    open UserQueries
+    open System.IO
+    open UserQueries
+    open Minio
+    open Minio.DataModel.Args
+    open Microsoft.Extensions.Configuration
+
+    [<CLIMutable>]
+    type FormModel = { Image: IFormFile; Test: string }
+    // Check if file is an image based on MIME type
+    let isImage (contentType: string) =
+        match contentType with
+        | "image/jpeg"
+        | "image/png"
+        | "image/gif" -> true
+        | _ -> false
+
+    let getPublicBlobUrl (config: IConfiguration) blobName =
+        let minioSettings = config.GetSection("Minio")
+        minioSettings.GetValue<string>("PublicBucketUrl") + blobName
+
+    let private processHttpFileRequest (next: HttpFunc) (ctx: HttpContext) handler =
+        task {
+            match ctx.Request.HasFormContentType with
+            | true ->
+                let! form = ctx.Request.ReadFormAsync() |> Async.AwaitTask
+                let files = form.Files
+
+                if files.Count > 0 then
+                    let file = files.[0]
+                    return! handler file
+                else
+                    return! badRequest (text "No files uploaded") next ctx
+            | false -> return! badRequest (text "Unsupported media type") next ctx
+        }
+
+    let private uploadProfilePicture (userId: string) (next: HttpFunc) (ctx: HttpContext) (file: IFormFile) =
+        task {
+            let containerClient = ctx.GetService<IMinioClient>()
+            let minioSettings = ctx.GetService<IConfiguration>().GetSection("Minio")
+
+            let guid = Guid.NewGuid().ToString() + Path.GetExtension(file.FileName)
+
+            let fileModel =
+                { UserId = userId
+                  BlobName = guid
+                  OriginalFilename = file.FileName }
+
+            use stream = file.OpenReadStream()
+
+            let putArgs =
+                (new PutObjectArgs())
+                    .WithBucket(minioSettings.GetValue<string>("PublicBucketName"))
+                    .WithObject(fileModel.BlobName)
+                    .WithObjectSize(stream.Length)
+                    .WithContentType(file.ContentType)
+                    .WithStreamData(stream)
+
+            let! _ = containerClient.PutObjectAsync(putArgs)
+            let! _ = upsertProfilePicture ctx fileModel
+
+            let blobUrl = getPublicBlobUrl minioSettings fileModel.BlobName
+            return! text blobUrl next ctx
+        }
+
+    let profilePictureUploadHandler (next: HttpFunc) (ctx: HttpContext) =
+        let userId = ctx.User.Identity.Name
+        uploadProfilePicture userId next ctx |> processHttpFileRequest next ctx
+
+
+//Note:
+// let presignesArgs =
+//     (new PresignedGetObjectArgs())
+//         .WithBucket("public-jehovahs-pictures")
+//         .WithObject(guidName)
+//         .WithExpiry(60)
+
+// let! z = containerClient.PresignedGetObjectAsync(presignesArgs)

DapperHelper.fs

@@ -0,0 +1,39 @@
+module Dapper.Extensions
+
+open System
+open Dapper
+
+let extractValue (x: obj) =
+    match x with
+    | null -> null
+    | _ ->
+        match x.GetType().GetProperty("Value") with
+        | null -> x
+        | prop -> prop.GetValue(x)
+
+let (+>) (map: Map<string, obj>) (key, value) = map.Add(key, extractValue value)
+let singleParam (key, value) = (Map.empty) +> (key, value)
+
+type OptionHandler<'T>() =
+    inherit SqlMapper.TypeHandler<option<'T>>()
+
+    override __.SetValue(param, value) =
+        let valueOrNull =
+            match value with
+            | Some x -> box x
+            | None -> null
+
+        param.Value <- valueOrNull
+
+    override __.Parse value =
+        if isNull value || value = box DBNull.Value then
+            None
+        else
+            Some(value :?> 'T)
+
+let registerTypeHandlers () =
+    SqlMapper.AddTypeHandler(OptionHandler<Guid>())
+    SqlMapper.AddTypeHandler(OptionHandler<int64>())
+    SqlMapper.AddTypeHandler(OptionHandler<int>())
+    SqlMapper.AddTypeHandler(OptionHandler<string>())
+    SqlMapper.AddTypeHandler(OptionHandler<DateTime>())

Dockerfile

@@ -0,0 +1,17 @@
+FROM mcr.microsoft.com/dotnet/sdk:7.0-alpine AS build
+
+WORKDIR /app
+
+# Copy source code and compile
+COPY ./ ./
+RUN dotnet restore
+
+RUN dotnet publish -o bin
+
+# Build runtime image
+FROM mcr.microsoft.com/dotnet/aspnet:7.0-alpine AS runtime
+
+WORKDIR /app
+COPY --from=build /app/bin .
+
+ENTRYPOINT ["dotnet", "SigmaChatServer.App.dll"]