Building a Real-Time Dispatch Console with AWS Serverless Architecture

                           ┌──────────────────────────────────────────────┐
                           │      EcoLink Operations Console (Client)     │
                           └───────────────┬──────────────────────────────┘
                                           │
                        Cognito ID Token   │   Map Tiles (API Key)
                    ┌──────────────────────┴──────────────────────┐
                    ▼                                             ▼
       ┌────────────────────────┐                    ┌────────────────────────┐
       │   Amazon API Gateway   │                    │ Amazon Location Service│
       │   (prod / 50 req/s)    │                    │ (ecolink-dispatch-map) │
       └───────────┬────────────┘                    └────────────────────────┘
                   │
         Cognito Authorizer
    ┌──────────────┴──────────────┐
    ▼                             ▼
┌───────────────┐         ┌───────────────┐
│  DashboardFn  │         │   PickupsFn   │
└───────┬───────┘         └───────┬───────┘
        │                         │
        ├─────────────────────────┼─────────────────────────┐
        ▼                         ▼                         ▼
┌───────────────┐         ┌───────────────┐         ┌───────────────┐
│  EcoLink-     │         │  EcoLink-     │         │  EcoLink-     │
│  recyclers    │         │  pickups      │         │  users        │
│  (DynamoDB)   │         │  (DynamoDB)   │         │  (DynamoDB)   │
└───────────────┘         └───────────────┘         └───────────────┘
        │                         │                         │
        └─────────────────────────┼─────────────────────────┘
                                  ▼
                          ┌───────────────┐
                          │  EcoLink-     │
                          │  conversation-│
                          │  state (DDB)  │
                          └───────────────┘

# backend/ecolink/handlers/auth.py
resp = client.initiate_auth(
    ClientId=client_id,
    AuthFlow="USER_PASSWORD_AUTH",
    AuthParameters={"USERNAME": email, "PASSWORD": password}
)
result = resp["AuthenticationResult"]
claims = _claims(result["IdToken"])
groups = claims.get("cognito:groups") or []

return {
    "id_token": result["IdToken"],
    "expires_in": result.get("ExpiresIn", 3600),
    "user": {"email": claims.get("email", email)},
    "group": "admins" if "admins" in groups else "viewers",
}

# backend/ecolink/core/dashboard_view.py
def build_views(repo: Any, pickups: list[dict[str, Any]], *, privileged: bool) -> list[dict[str, Any]]:
    views = []
    for pickup in pickups:
        show_private = privileged or address_visible(pickup.get("status"))
        view = pickup_view(pickup, privileged=privileged)
        
        if show_private:
            household = user(pickup["user_id"])
            if household.get("lat") is not None and household.get("lng") is not None:
                view["lat"], view["lng"] = household["lat"], household["lng"]
        else:
            view["address_text"] = "[Hidden until confirmed]"
            view["user_id"] = "User (protected)"
            # lat and lng remain omitted, preventing map pin leaks
        views.append(view)
    return views

# backend/ecolink/handlers/dashboard.py
def users(event: dict, context: Any) -> dict[str, list[dict[str, Any]]]:
    repo = deps.get_repo()
    states = {row["user_id"]: _decode_state(row) for row in repo.list_conversation_states()}
    rows = []
    for user in sorted(repo.list_users(), key=lambda row: row.get("user_id", "")):
        uid = user["user_id"]
        state = states.get(uid, {})
        pickup_count = len(repo.list_pickups(user_id=uid, limit=100))
        rows.append({
            "user_id": uid,
            "name": user.get("name"),
            "lang": user.get("lang", state.get("lang", "en")),
            "pickup_count": pickup_count,
            "conversation_state": state,
        })
    return {"users": rows}

// frontend/dashboard/app.js
const cfg = window.ECOLINK_CONFIG.amazonLocation;
const style = `https://maps.geo.${cfg.region}.amazonaws.com/maps/v0/maps/${cfg.mapName}/style-descriptor?key=${cfg.apiKey}`;

alMap = new maplibregl.Map({
  container: 'map-canvas',
  style: style,
  center: [77.5946, 12.9716], // Bengaluru Hub
  zoom: 11
});



aws cognito-idp admin-create-user \
  --user-pool-id <UserPoolId> \
  --username ops@ecolink.internal \
  --user-attributes Name=email,Value=ops@ecolink.internal Name=email_verified,Value=true \
  --message-action SUPPRESS

aws cognito-idp admin-set-user-password \
  --user-pool-id <UserPoolId> \
  --username ops@ecolink.internal \
  --password 'EcoLink2026!Aws' \
  --permanent

aws cognito-idp admin-add-user-to-group \
  --user-pool-id <UserPoolId> \
  --username ops@ecolink.internal \
  --group-name admins

window.ECOLINK_CONFIG = {
  mockMode: false,
  baseUrl: 'https://<ApiGatewayId>.execute-api.<region>.amazonaws.com/prod',
  cognito: {
    userPoolId: '<UserPoolId>',
    clientId: '<UserPoolClientId>',
    region: '<region>'
  },
  amazonLocation: {
    region: '<region>',
    mapName: 'ecolink-dispatch-map',
    apiKey: '<AmazonLocationApiKey>'
  }
};

python scripts/serve_dashboard.py
# Open http://localhost:8000/dashboard in your browser