mirror of
https://github.com/fluencelabs/fluid
synced 2025-04-11 14:46:10 +00:00
39 lines
1.2 KiB
TypeScript
39 lines
1.2 KiB
TypeScript
import {Action, decode, FetchRequest, PostRequest} from "./request";
|
|
import {PostResponse, Message, FetchResponse, UnknownResponse} from "./response";
|
|
|
|
let messageList: Array<Message> = new Array<Message>();
|
|
|
|
// main handler for an application
|
|
export function handler(input: string): string {
|
|
|
|
let request = decode(input);
|
|
|
|
if (request.action == Action.Post) {
|
|
let post = request as PostRequest;
|
|
messageList.push(new Message(post.msg, post.handle));
|
|
let response = new PostResponse(messageList.length);
|
|
return response.serialize()
|
|
} else if (request.action == Action.Fetch) {
|
|
let fetch = request as FetchRequest;
|
|
var messages: Array<Message>;
|
|
if (fetch.filter_handle == null) {
|
|
messages = messageList
|
|
} else {
|
|
let filter_handle = fetch.filter_handle as string;
|
|
let filtered = new Array<Message>();
|
|
for (let i = 0; i < messageList.length; i++) {
|
|
let message = messageList[i];
|
|
if (message.handle == filter_handle) {
|
|
filtered.push(message)
|
|
}
|
|
}
|
|
messages = filtered;
|
|
}
|
|
let response = new FetchResponse(messages);
|
|
return response.serialize()
|
|
}
|
|
|
|
let response = new UnknownResponse();
|
|
return response.serialize();
|
|
}
|