Skip to content

zekenie/web-reducer

main
Switch branches/tags

Name already in use

A tag already exists with the provided branch name. Many Git commands accept both tag and branch names, so creating this branch may cause unexpected behavior. Are you sure you want to create this branch?
Code

Latest commit

 

Git stats

Files

Permalink
Failed to load latest commit information.
Type
Name
Latest commit message
Commit time
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 

Web Reducer Logo

Warning This project is very much an unstable work in progress. Follow along on my blog to see my process.

Screenshot

What is WebReducer

WebReducer is the simplest way to get a stateful endpoint online. You define a few functions that configure the behavior of your endpoint and we handle the rest. You can think of it like an HTTP endpoint + Redux reducer, if that makes any sense to you.

Here's a pseudo-code version of how WebReducer works:

server.on("request", async (req, res) => {
  const yourResponse = yourResponderFunction(req.body);
  res.status(yourResponse.statusCode);
  res.send(yourResponse.body);
  const currentState = await lookupCurrentState();
  const yourSecrets = await lookupYourSecrets();
  const nextState = yourReducerFunction(currentState, req.body, yourSecrets);
  await saveNextState(nextState);
});

In reality, it's a lot more complex than this. But this can give you an adequate mental model of the system.

Here's a diagram.

    .─────────────────────────────.
   (     Your producer client      )
    `───────┬─────▲───────────────'
            │     │
┌ ─ ─ ─ ─ ─ ┼ ─ ─ ┼ ─ ─ ─ ─ ─ ─ ─ ─ ─ ┐
        ┌───▼─────┴──┐
│       │ /:writeKey ├┐               │
        └┬───────────┘├┐
│        └┬───────────┘│              │
          └─┬────────▲─┘
│           │        │                │
       ┌────▼────────┴────┐
│      │  responder(req)  │           │
       └────┬─────────────┘
│           │                         │
    ┌───────▼────────────────┐
│   │ getIdempotencyKey(req) │        │
    └───────┬────────────────┘
│           │                         │
      ┌─────▼────────┐
│     │reducer(      │       .─────.  │
      │  prevState,◀─┼──────(       )
│     │  req,        │      (`─────') │
      │  secrets     │      (`─────')
│     │) -> nextState├─────▶(`─────') │
      └──────────────┘       `──┬──'
│                               │     │
    ┌─────────────────────────┐ │
│   │query(state, queryString)│◀┘     │
    └────────────┬────────────┘
│                │                    │
         ┌───────▼────┐
│        │ /:readKey  ├┐              │
         └┬───────────┘├┐
│         └┬───────────┘│             │
           └──┬─────▲───┘
└ ─ ─ ─ ─ ─ ─ ┼ ─ ─ ┼ ─ ─ ─ ─ ─ ─ ─ ─ ┘
              │     │
    .─────────▼─────┴───────────.
   (    Your consumer client     )
    `───────────────────────────'

Service Level Diagram

flowchart LR
    Client[Remix App]
    Browser
    HookClient[Endpoint Clients]
    subgraph privateNetwork[Private Network]

        Server
        Redis[(Redis)]
        Postgres[(Postgres)]
        SecretsDb[(SecretsDb)]
        Worker
        Secrets[Secrets Service]
        subgraph isolated-docker
            Runner
        end
    end

    click Client "https://github.com/zekenie/web-reducer/tree/main/client#readme"
    click Server "https://github.com/zekenie/web-reducer/tree/main/server#readme"
    click Worker "https://github.com/zekenie/web-reducer/tree/main/server#readme"
    click Secrets "https://github.com/zekenie/web-reducer/tree/main/secrets#readme"
    click Runner "https://github.com/zekenie/web-reducer/tree/main/runner#readme"


    Client <--> Server
    Server --> Secrets
    HookClient <--> Client
    Secrets <--> SecretsDb
    Server <--> Redis
    Server <--> Postgres
    Worker <--> Redis
    Worker <--> Postgres
    Worker <--> Runner
    Browser <--> Client
    Redis

classDef selected stroke-width:4px;

Use cases

(this is an active brainstorm)

  • Prototyping

    • Often times when you're working on a new project, it's somewhere between prototype and production application. Maybe you don't have as many tests as you normally would. Maybe you don't have as much observability as you might want. Maybe you don't handle webhooks all that well. Start with hook reducer. Put it in front of your project.
    • Maybe you have a new integration in your product. It's immature, and you're not sure if it'll stick around. They have a webhook feature, but you don't want to do the legwork to setup a queue, validate authenticity, etc, etc, etc. Put WR in front of your app. Write your reducer function later if you ever need it.
    • Your building a client-side prototype and don't want to bother with a real backend, but would love to save a little data somewhere. We've got you covered
  • IOT

    • Do you have devices out in the world that are intermittently connected? Maybe you want them to be able to connect to a server and ask "what happened since I last had a connection." WR is perfect for that.
  • Games

    • You want multiple players to agree on the state of the world
    • Multiple players can send in events
    • All players are notified via websocket when the state of the world changes
  • Debugging

    • ??
  • Personal

Hygen templates

$ hygen new worker|email|etc

Maintenance

  • Upgrade packages in every js project
  • For docker images
    • docker pull node:lts-alpine
    • Take out the digest and put it in the docker files

2/27/22

  • Auth should not be in authn
  • we should use our own stuff
  • every request sends a auth header
    • auth header is base64 encoded json
    • it contains
      • a visitor id
      • conditionally a jwt.
    • many routes will be able to be hit w/ just a visitor id
    • upon authentication, everything the visitor owns will be merged with the prior user
    • modeling visitors
      • maybe a user with type = visitor? <-- that one
      • maybe its own table, with a userid column
    • authentication happens via email
      • we sign a jwt when we see a req with a preapproved code
      • that code is sent via email
      • modeling login tokens
        • table for login tokens
        • expiry = 1h
      • able to set a pin on acct if you want
    • req.user will always be defined, even if there's no jwt
    • when you login with an email link, you get a jwt, and your visitor id is updated
    • if you try to use a uuid that is a non-visitor id (already tied to an account), but you don't have a jwt, you are denied
  • Capabilities we need
    • reading and writing auth header
    • sending email
    • storing login tokens

3/6/22 state dump

3/28/22

  • Auth layer is sort of working!
  • Made some changes to above.
    • instead of using unsigned jwt for visitors, we hit an endpoint to sign up a new visitor
    • this is because i thought it could be a single point to eliminate abuse (block signups from ip, capcha, etc)
    • some integration tests of access and auth
  • ran security & dependency updates
  • considering doing the FE in remix and hitting the express API from backend to backend

4/1/22

  • Refresh tokens seem to be working ok
  • next up is probably publishing draft

4/4/22

  • CloudEvents are a spec for various event types... I think that should be used instead of our request schema.

About

Simple, functional & stateful faas environment

Resources

License

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published