echo-d 0.0.0

ECS networking
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115

use crate::options::{Options, OptionsExtended};
use crate::symbols::extract_symbol;
use crate::context::Context;

/**
 * The Payload struct represents the payload for an actor action.
 */
pub struct ActorPayload {
    pub id: any,
}

/**
 * The ActorActions struct represents actions that can be performed on actors.
 * This struct encapsulates the logic for merging, spawning, removing, and handling input for actors.
 */
pub trait ActorActions {
    /**
     * Handles input for a specific actor in the current context.
     */
    pub fn actor_input(&self, payload: Payload, context: Context, options: Options) {
        let Options { compress_strings_as_ints, get_actor_id, skip_pending } = options;

        let mut id = get_actor_id(payload.id, context);
        if id.is_none() || id.unwrap().is_empty() {
            return;
        }

        if compress_strings_as_ints {
            id = extract_symbol(id.unwrap(), context, options);
            if id.unwrap().is_empty() {
                return;
            }
        }

        if payload.id.is_none() {
            payload.id = id;
        }

        context.actor_input(id.unwrap(), payload, skip_pending);
    }

    /**
     * Retrieves actors from the current context and sends them to the responder.
     */
    pub fn actors(&self, _payload: any, context: Context, options: Options) {
        let OptionsExtended { responder, enum_default_symbols } = options;

        let actors = context.actors;
        responder([enum_default_symbols.mergeActors, actors]);
    }

    /**
     * Merges actors into the current context.
     */
    pub fn merge_actors(&self, payload: Payload, context: Context, options: Options) {
        context.merge_actors(payload, options);
    }

    /**
     * Removes an actor from the current context.
     */
    pub fn remove_actor(&self, id: any, context: Context, options: Options) {
        let Options { compress_strings_as_ints, get_actor_id, skip_pending } = options;

        let mut id = get_actor_id(id, context);
        if id.is_none() || id.unwrap().is_empty() {
            return;
        }

        if compress_strings_as_ints {
            id = extract_symbol(id.unwrap(), context, options);
            if id.unwrap().is_empty() {
                return;
            }
        }

        context.remove_actor(id.unwrap(), skip_pending);
    }

    /**
     * Spawns a new actor in the current context.
     */
    pub fn spawn_actor(&self, id: any, context: Context, options: Options) {
        let Options { compress_strings_as_ints, get_actor_id, skip_pending } = options;

        let mut id = get_actor_id(id, context);
        if id.is_none() || id.unwrap().is_empty() {
            return;
        }

        if compress_strings_as_ints {
            id = extract_symbol(id.unwrap(), context, options);
            if id.unwrap().is_empty() {
                return;
            }
        }

        context.spawn_actor(id.unwrap(), skip_pending);
    }
}

pub struct Actions {}

impl ActorActions for Actions {}

/**
 * An object that maps the names of actions to their corresponding methods in the ActorActions struct.
 */
pub const ACTIONS: Actions = HashMap<&str, fn> {
    "actorInput": ActorActions::actor_input,
    "actors": ActorActions::actors,
    "mergeActors": ActorActions::merge_actors,
    "removeActor": ActorActions::remove_actor,
    "spawnActor": ActorActions::spawn_actor,
};