gRPC snowflake server

Cargo.toml

@@ -1,5 +1,5 @@
 [package]
-name = "snowflake"
+name = "snowflake_service"
 version = "0.1.0"
 authors = ["Dustin Pianalto <dustin@djpianalto.com>"]
 edition = "2018"
@@ -7,3 +7,9 @@ edition = "2018"
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
 
 [dependencies]
+tonic = "0.4"
+prost = "0.7"
+tokio = { version = "1.0", features = ["macros", "rt-multi-thread"] }
+
+[build-dependencies]
+tonic-build = "0.4"

build.rs

@@ -0,0 +1,4 @@
+fn main() -> Result<(), Box<dyn std::error::Error>> {
+    tonic_build::compile_protos("proto/snowflake.proto")?;
+    Ok(())
+}

proto/snowflake.proto

@@ -0,0 +1,15 @@
+syntax = "proto3";
+package snowflake;
+
+message Empty {
+
+}
+
+message SnowflakeReply {
+  string id_str = 1;
+  uint64 id = 2;
+}
+
+service Snowflake {
+  rpc GetSnowflake (Empty) returns (SnowflakeReply);
+}

src/lib.rs

@@ -1,3 +1,52 @@
-pub fn run() {
+use std::time;
-    println!("Hello, world!");
+use std::sync::Mutex;
+use std::convert::TryInto;
+
+const EPOCH_TIME: time::Duration = time::Duration::from_millis(1609459200000);
+const TIME_MASK: u64 = 0x1FFFFFFFFFF;
+
+#[derive(Debug, Default)]
+pub struct Generator {
+    last_generated_time: Mutex<u64>,
+    counter: Mutex<u64>,
+    last_counter_rollover: Mutex<u64>,
+    worker_id: u64,
+}
+
+impl Generator {
+    pub fn new(worker_id: u64) -> Generator {
+        if worker_id > 1023 {
+            panic!("Invalid worker id")
+        }
+        Generator {
+            last_generated_time: Mutex::new(0),
+            counter: Mutex::new(0),
+            last_counter_rollover: Mutex::new(0),
+            worker_id: worker_id << 12,
+        }
+    }
+
+    pub fn generate_snowflake(&self) -> Result<u64, &str> {
+        let time: u64 = match time::SystemTime::now().duration_since(time::SystemTime::UNIX_EPOCH + EPOCH_TIME) {
+            Ok(t) => t.as_millis().try_into().unwrap(),
+            Err(_) => return Err("The epoch appears to be in the past! Check the system time."),
+        };
+        let mut last_generated_time = self.last_generated_time.lock().unwrap();
+        let mut counter = self.counter.lock().unwrap();
+        let mut last_counter_rollover = self.last_counter_rollover.lock().unwrap();
+        if time < *last_generated_time {
+            return Err("The current time is less than the last generated time! Check the system time.");
+        }
+        if *counter == 4095 {
+            if *last_counter_rollover >= time {
+                return Err("Too many requests in the current ms");
+            }
+            *last_counter_rollover = time;
+            *counter = 0;
+        } else {
+            *counter += 1;
+        }
+        *last_generated_time = time;
+        Ok(((time & TIME_MASK) << 22) + self.worker_id + *counter)
+    }
 }

src/main.rs

@@ -1,5 +1,58 @@
-use snowflake;
+use snowflake_service;
+use std::env;
 
-fn main() {
+use tonic::{transport::Server, Request, Response, Status};
-    snowflake::run();
+
+use snowflake::snowflake_server::{Snowflake, SnowflakeServer};
+use snowflake::{Empty, SnowflakeReply};
+
+pub mod snowflake {
+    tonic::include_proto!("snowflake");
+}
+
+#[derive(Debug, Default)]
+pub struct MySnowflake {
+    generator: snowflake_service::Generator,
+}
+
+impl MySnowflake {
+    fn new(worker_id: u64) -> MySnowflake {
+        let s = snowflake_service::Generator::new(worker_id);
+        MySnowflake{
+            generator: s,
+        }
+    }
+
+}
+
+#[tonic::async_trait]
+impl Snowflake for MySnowflake {
+    async fn get_snowflake(&self, _request: Request<Empty>) -> Result<Response<SnowflakeReply>, Status> {
+        let id = match self.generator.generate_snowflake() {
+            Ok(i) => i,
+            Err(s) => return Err(Status::resource_exhausted(s)),
+        };
+        let reply = SnowflakeReply {
+            id,
+            id_str: id.to_string(),
+        };
+        Ok(Response::new(reply))
+    }
+}
+
+#[tokio::main]
+async fn main() -> Result<(), Box<dyn std::error::Error>> {
+    let addr = "0.0.0.0:50051".parse()?;
+    let worker_id: u64 = match env::var("WORKER_ID") {
+        Ok(id) => id.parse::<u64>().unwrap(),
+        Err(_) => panic!("No WORKER_ID env variable found"),
+    };
+    let s = MySnowflake::new(worker_id);
+    
+    Server::builder()
+        .add_service(SnowflakeServer::new(s))
+        .serve(addr)
+        .await?;
+
+    Ok(())
 }