followed docs on server setup
This commit is contained in:
parent
8bfd441c34
commit
083b580040
6 changed files with 174 additions and 0 deletions
10
README.md
10
README.md
|
|
@ -34,3 +34,13 @@ And enable WebAssembly:
|
|||
```bash
|
||||
dotnet workload install wasi-experimental
|
||||
```
|
||||
|
||||
```bash
|
||||
bun server:up
|
||||
```
|
||||
|
||||
Add the spacetime docker server to your cli
|
||||
|
||||
```bash
|
||||
spacetime server add --url http://localhost:3000 massive
|
||||
```
|
||||
|
|
|
|||
26
massive.sln
Normal file
26
massive.sln
Normal file
|
|
@ -0,0 +1,26 @@
|
|||
|
||||
Microsoft Visual Studio Solution File, Format Version 12.00
|
||||
# Visual Studio Version 17
|
||||
VisualStudioVersion = 17.0.31903.59
|
||||
MinimumVisualStudioVersion = 10.0.40219.1
|
||||
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "StdbModule", "server\StdbModule.csproj", "{25B51793-082D-44ED-A8D2-4A87A11F1882}"
|
||||
EndProject
|
||||
Global
|
||||
GlobalSection(SolutionConfigurationPlatforms) = preSolution
|
||||
Debug|Any CPU = Debug|Any CPU
|
||||
Release|Any CPU = Release|Any CPU
|
||||
EndGlobalSection
|
||||
GlobalSection(SolutionProperties) = preSolution
|
||||
HideSolutionNode = FALSE
|
||||
EndGlobalSection
|
||||
GlobalSection(ProjectConfigurationPlatforms) = postSolution
|
||||
{BDFCBF69-C44E-4188-A9FC-2CFED6EC2246}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
|
||||
{BDFCBF69-C44E-4188-A9FC-2CFED6EC2246}.Debug|Any CPU.Build.0 = Debug|Any CPU
|
||||
{BDFCBF69-C44E-4188-A9FC-2CFED6EC2246}.Release|Any CPU.ActiveCfg = Debug|Any CPU
|
||||
{BDFCBF69-C44E-4188-A9FC-2CFED6EC2246}.Release|Any CPU.Build.0 = Debug|Any CPU
|
||||
{25B51793-082D-44ED-A8D2-4A87A11F1882}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
|
||||
{25B51793-082D-44ED-A8D2-4A87A11F1882}.Debug|Any CPU.Build.0 = Debug|Any CPU
|
||||
{25B51793-082D-44ED-A8D2-4A87A11F1882}.Release|Any CPU.ActiveCfg = Release|Any CPU
|
||||
{25B51793-082D-44ED-A8D2-4A87A11F1882}.Release|Any CPU.Build.0 = Release|Any CPU
|
||||
EndGlobalSection
|
||||
EndGlobal
|
||||
2
server/.gitignore
vendored
Normal file
2
server/.gitignore
vendored
Normal file
|
|
@ -0,0 +1,2 @@
|
|||
bin
|
||||
obj
|
||||
116
server/Lib.cs
Normal file
116
server/Lib.cs
Normal file
|
|
@ -0,0 +1,116 @@
|
|||
using SpacetimeDB;
|
||||
|
||||
public static partial class Module
|
||||
{
|
||||
[Table(Name = "User", Public = true)]
|
||||
public partial class User
|
||||
{
|
||||
[PrimaryKey]
|
||||
public Identity Identity;
|
||||
public string? Name;
|
||||
public bool Online;
|
||||
}
|
||||
|
||||
[Table(Name = "Message", Public = true)]
|
||||
public partial class Message
|
||||
{
|
||||
public Identity Sender;
|
||||
public Timestamp Sent;
|
||||
public string Text = "";
|
||||
}
|
||||
|
||||
[Reducer]
|
||||
public static void SetName(ReducerContext ctx, string name)
|
||||
{
|
||||
name = ValidateName(name);
|
||||
|
||||
var user = ctx.Db.User.Identity.Find(ctx.Sender);
|
||||
if (user is not null)
|
||||
{
|
||||
user.Name = name;
|
||||
ctx.Db.User.Identity.Update(user);
|
||||
}
|
||||
}
|
||||
|
||||
/// Takes a name and checks if it's acceptable as a user's name.
|
||||
private static string ValidateName(string name)
|
||||
{
|
||||
if (string.IsNullOrEmpty(name))
|
||||
{
|
||||
throw new Exception("Names must not be empty");
|
||||
}
|
||||
return name;
|
||||
}
|
||||
|
||||
[Reducer]
|
||||
public static void SendMessage(ReducerContext ctx, string text)
|
||||
{
|
||||
text = ValidateMessage(text);
|
||||
Log.Info(text);
|
||||
ctx.Db.Message.Insert(
|
||||
new Message
|
||||
{
|
||||
Sender = ctx.Sender,
|
||||
Text = text,
|
||||
Sent = ctx.Timestamp,
|
||||
}
|
||||
);
|
||||
}
|
||||
|
||||
/// Takes a message's text and checks if it's acceptable to send.
|
||||
private static string ValidateMessage(string text)
|
||||
{
|
||||
if (string.IsNullOrEmpty(text))
|
||||
{
|
||||
throw new ArgumentException("Messages must not be empty");
|
||||
}
|
||||
return text;
|
||||
}
|
||||
|
||||
[Reducer(ReducerKind.ClientConnected)]
|
||||
public static void ClientConnected(ReducerContext ctx)
|
||||
{
|
||||
Log.Info($"Connect {ctx.Sender}");
|
||||
var user = ctx.Db.User.Identity.Find(ctx.Sender);
|
||||
|
||||
if (user is not null)
|
||||
{
|
||||
// If this is a returning user, i.e., we already have a `User` with this `Identity`,
|
||||
// set `Online: true`, but leave `Name` and `Identity` unchanged.
|
||||
user.Online = true;
|
||||
ctx.Db.User.Identity.Update(user);
|
||||
}
|
||||
else
|
||||
{
|
||||
// If this is a new user, create a `User` object for the `Identity`,
|
||||
// which is online, but hasn't set a name.
|
||||
ctx.Db.User.Insert(
|
||||
new User
|
||||
{
|
||||
Name = null,
|
||||
Identity = ctx.Sender,
|
||||
Online = true,
|
||||
}
|
||||
);
|
||||
}
|
||||
}
|
||||
|
||||
[Reducer(ReducerKind.ClientDisconnected)]
|
||||
public static void ClientDisconnected(ReducerContext ctx)
|
||||
{
|
||||
var user = ctx.Db.User.Identity.Find(ctx.Sender);
|
||||
|
||||
if (user is not null)
|
||||
{
|
||||
// This user should exist, so set `Online: false`.
|
||||
user.Online = false;
|
||||
ctx.Db.User.Identity.Update(user);
|
||||
}
|
||||
else
|
||||
{
|
||||
// User does not exist, log warning
|
||||
Log.Warn("Warning: No user found for disconnected client.");
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
14
server/StdbModule.csproj
Normal file
14
server/StdbModule.csproj
Normal file
|
|
@ -0,0 +1,14 @@
|
|||
<Project Sdk="Microsoft.NET.Sdk">
|
||||
|
||||
<PropertyGroup>
|
||||
<TargetFramework>net8.0</TargetFramework>
|
||||
<RuntimeIdentifier>wasi-wasm</RuntimeIdentifier>
|
||||
<ImplicitUsings>enable</ImplicitUsings>
|
||||
<Nullable>enable</Nullable>
|
||||
</PropertyGroup>
|
||||
|
||||
<ItemGroup>
|
||||
<PackageReference Include="SpacetimeDB.Runtime" Version="1.1.*" />
|
||||
</ItemGroup>
|
||||
|
||||
</Project>
|
||||
6
server/global.json
Normal file
6
server/global.json
Normal file
|
|
@ -0,0 +1,6 @@
|
|||
{
|
||||
"sdk": {
|
||||
"version": "8.0.400",
|
||||
"rollForward": "latestMinor"
|
||||
}
|
||||
}
|
||||
Loading…
Add table
Reference in a new issue