MCPcopy Create free account

hub / github.com/almetica/almetica / functions

Functions372 in github.com/almetica/almetica

↓ 130 callersMethodrun
Starts the main loop of the global world.
src/ecs/world.rs:60
↓ 55 callersFunctiondb_test
Executes a test with a database connection. Prepares a new test database that is cleaned up after the test. Configure the TEST_DATABASE_CONNECTION in
src/model.rs:472
↓ 24 callersFunctioncreate
Creates a new user.
src/model/repository/user.rs:8
↓ 20 callersFunctionsend_message
Send a message using the given channel.
src/ecs/system.rs:21
↓ 19 callersFunctionsend_message_to_connection
Send an outgoing packet message. This function can't be used by "Special Messages".
src/ecs/system/local.rs:12
↓ 18 callersMethodapply_keystream
(&mut self, data: &mut [u8])
src/crypt/pike.rs:55
↓ 11 callersFunctionsetup_with_connection
( pool: PgPool, )
src/ecs/system/global/user_manager.rs:673
↓ 9 callersFunctionget_default_user
(account: &Account, num: i32)
src/model/repository/user.rs:178
↓ 9 callersFunctionsetup_with_connection
( pool: PgPool, is_authenticated: bool, )
src/ecs/system/global/connection_manager.rs:501
↓ 8 callersFunctioncreate_account
(pool: &mut PgConnection)
src/model/repository/user.rs:166
↓ 8 callersMethodcrypt_client_data
(&mut self, data: &mut [u8])
src/crypt.rs:62
↓ 8 callersFunctionget_by_id
Finds an user by id.
src/model/repository/user.rs:107
↓ 7 callersFunctionget_default_account
(num: i32)
src/model/repository/account.rs:85
↓ 7 callersMethodserialize
(&self, serializer: S)
src/model.rs:139
↓ 7 callersFunctionsetup_cipher
()
src/crypt/pike.rs:155
↓ 7 callersFunctionupsert_ticket
Upserts a ticket (randomly generated 128 bytes). Tickets are valid for 5 minutes and can only be used once.
src/model/repository/loginticket.rs:10
↓ 6 callersFunctioncreate
Creates a new account.
src/model/repository/account.rs:9
↓ 6 callersFunctionget_by_user_id
Get the location of a user.
src/model/repository/user_location.rs:33
↓ 6 callersFunctionlist
Get all users of an account.
src/model/repository/user.rs:126
↓ 6 callersFunctionsetup
( pool: PgPool, )
src/ecs/system/global/local_world_manager.rs:274
↓ 6 callersFunctionsetup_session
()
src/crypt.rs:95
↓ 5 callersMethodabs_offset
(&self, offset: usize)
src/protocol/serde/de.rs:33
↓ 5 callersFunctioncreate
Creates a new user location.
src/model/repository/user_location.rs:11
↓ 5 callersFunctioncreate_local_world
( world: &mut World, global_world_channel: &Sender<EcsMessage>, conf: &Configuration,
src/ecs/system/global/local_world_manager.rs:384
↓ 5 callersFunctioncreate_user
(conn: &mut PgConnection, account_id: i64, num: i32)
src/ecs/system/global/user_manager.rs:735
↓ 5 callersMethodcrypt_server_data
(&mut self, data: &mut [u8])
src/crypt.rs:69
↓ 5 callersFunctionget_user_count
Get the user count of an account.
src/model/repository/user.rs:117
↓ 5 callersFunctionsetup
( pool: &PgPool, )
src/ecs/system/global/user_spawner.rs:462
↓ 5 callersFunctionto_vec
Serializes the given structure into a `Vec<u8>` byte stream for the TERA network protocol.
src/protocol/serde/ser.rs:81
↓ 4 callersMethodcommit
(self: Box<Self>)
src/model/migrations.rs:176
↓ 4 callersFunctioncreate_login
(conn: &mut PgConnection)
src/ecs/system/global/connection_manager.rs:528
↓ 4 callersFunctionfrom_vec
Parses the given `Vec<u8>`
src/protocol/serde/de.rs:18
↓ 4 callersFunctionget_by_id
Finds an account by id.
src/model/repository/account.rs:37
↓ 4 callersFunctionget_by_name
Finds an account by name.
src/model/repository/account.rs:47
↓ 4 callersFunctionsetup_with_spawn
()
src/ecs/system/local/user_gateway.rs:297
↓ 3 callersFunctionassemble_can_create_user_response
(connection_global_world_id: EntityId, ok: bool)
src/ecs/system/global/user_manager.rs:492
↓ 3 callersFunctionassemble_check_user_name_response
(connection_global_world_id: EntityId, ok: bool)
src/ecs/system/global/user_manager.rs:506
↓ 3 callersFunctionassemble_create_user_packet
()
src/ecs/system/global/user_manager.rs:714
↓ 3 callersFunctionassemble_create_user_response
(connection_global_world_id: EntityId, ok: bool)
src/ecs/system/global/user_manager.rs:499
↓ 3 callersFunctionassemble_user_list_response
( connection_global_world_id: EntityId, users: &[User], is_first_page: bool, is_last_page: boo
src/ecs/system/global/user_manager.rs:520
↓ 3 callersFunctioncalculate_reverse_map
(opcode_mapping: &[Opcode])
src/dataloader.rs:68
↓ 3 callersFunctioncreate_hash
Creates a String that contains the hash of the given password hashed with the chosen password hash algorithm. Creates a random salt, which is saved al
src/crypt/password_hash.rs:14
↓ 3 callersFunctioncreate_response
(resp: &impl Serialize, status_code: StatusCode)
src/webserver.rs:123
↓ 3 callersFunctiondrop_connection
( connection_global_world_id: EntityId, connections: &mut ViewMut<GlobalConnection>, user_spawns:
src/ecs/system/global/connection_manager.rs:303
↓ 3 callersMethodprocess_message_block
(&mut self)
src/crypt/sha1.rs:46
↓ 3 callersFunctionread_opcode_table
Read the opcode mapping file and returns the opcode table.
src/dataloader.rs:56
↓ 3 callersFunctionrun
Parses the given tcp stream dump. File should be binary and contain the data as an array of items specified as: i8 server (1) or client (0) i64 lengt
src/bin/almetica-parse-stream.rs:53
↓ 3 callersFunctionsetup
(conn: &mut PgConnection)
src/model/repository/user_location.rs:93
↓ 3 callersFunctionshift_key
(dst: &mut [u8], src: &[u8], n: i32)
src/crypt.rs:74
↓ 3 callersFunctionupdate_lobby_slot
Updates the lobby_slot of an user with the given ID.
src/model/repository/user.rs:97
↓ 2 callersFunctionapply
(db_url: &str, db_name: &str)
src/model/migrations.rs:16
↓ 2 callersFunctionassemble_delete_user_response
(connection_global_world_id: EntityId, ok: bool)
src/ecs/system/global/user_manager.rs:513
↓ 2 callersFunctioncan_create_user
Returns true if the account has free character slots.
src/ecs/system/global/user_manager.rs:421
↓ 2 callersFunctioncheck_username
Returns true if the name is valid and is not taken.
src/ecs/system/global/user_manager.rs:407
↓ 2 callersMethodclock_keys
(&mut self)
src/crypt/pike.rs:104
↓ 2 callersFunctiondelete_by_id
Deletes an user with the given id.
src/model/repository/user.rs:146
↓ 2 callersMethoddeserialize_tuple
(self, count: usize, visitor: V)
src/protocol/serde/de.rs:294
↓ 2 callersMethodhandle_error
(&self, e: anyhow::Error)
src/protocol.rs:212
↓ 2 callersMethodhash
Calculate the final hash
src/crypt/sha1.rs:37
↓ 2 callersFunctioninvalid_login_response
(status_code: StatusCode)
src/webserver.rs:133
↓ 2 callersFunctionleft_rotate
(word: u32, shift: u32)
src/crypt/sha1.rs:141
↓ 2 callersFunctionload_opcode_mapping
Load opcode mapping from a file (normal and reverse lookup)
src/dataloader.rs:44
↓ 2 callersMethodparse_migration_version_name
(&self, migration_file_name: &str)
src/model/migrations.rs:221
↓ 2 callersFunctionread_configuration
(path: &PathBuf)
src/config.rs:44
↓ 2 callersFunctionrun_workload_tick
(world: &World, workload_name: &str, min_tick_duration: Duration)
src/ecs/world.rs:210
↓ 2 callersFunctionsetup
()
src/ecs/system/local/user_gateway.rs:284
↓ 2 callersFunctionsetup
(pool: PgPool)
src/ecs/system/global/connection_manager.rs:494
↓ 2 callersFunctionsqlx_pool
(config: &Configuration)
src/bin/almetica.rs:220
↓ 2 callersFunctionupdate
Updates an user.
src/model/repository/user.rs:41
↓ 2 callersMethodupdate
Update the hash with new data
src/crypt/sha1.rs:25
↓ 2 callersFunctionxor_key
(dst: &mut [u8], key1: &[u8], key2: &[u8])
src/crypt.rs:83
↓ 1 callersFunctionaccept_check_version
(connection_global_world_id: EntityId)
src/ecs/system/global/connection_manager.rs:414
↓ 1 callersFunctionaccept_login_arbiter
TODO read PVP option out of configuration
src/ecs/system/global/connection_manager.rs:429
↓ 1 callersFunctionapply_migration_file
( migration_file_name: &str, migration_sql: &str, migration: &mut Migration, )
src/model/migrations.rs:80
↓ 1 callersFunctionassemble_connection_registration_finished
(connection_global_world_id: EntityId)
src/ecs/system/global/connection_manager.rs:408
↓ 1 callersFunctionassemble_drop_connection
(connection_global_world_id: EntityId)
src/ecs/system/global/connection_manager.rs:402
↓ 1 callersFunctionassemble_loading_screen_info
(connection_global_world_id: EntityId)
src/ecs/system/global/connection_manager.rs:361
↓ 1 callersFunctionassemble_login_account_info
( connection_global_world_id: EntityId, server_name: String, account_id: i64, )
src/ecs/system/global/connection_manager.rs:380
↓ 1 callersMethodassemble_node
Recursively assemble to data nodes into one packet
src/protocol/serde/ser.rs:34
↓ 1 callersFunctionassemble_ping
(connection_global_world_id: EntityId)
src/ecs/system/global/connection_manager.rs:395
↓ 1 callersFunctionassemble_prepare_user_spawn
TODO we somehow need to track the "is_alive" status between spawns
src/ecs/system/global/user_spawner.rs:428
↓ 1 callersFunctionassemble_register_local_world
( connection_local_world_id: EntityId, local_world_channel: Sender<EcsMessage>, )
src/ecs/system/global/user_spawner.rs:298
↓ 1 callersFunctionassemble_remain_play_time
(connection_global_world_id: EntityId)
src/ecs/system/global/connection_manager.rs:370
↓ 1 callersFunctionassemble_response_load_hint
(connection_global_world_id: EntityId)
src/ecs/system/global/user_spawner.rs:414
↓ 1 callersFunctionassemble_response_load_topo
( connection_global_world_id: EntityId, user_location: &UserLocation, )
src/ecs/system/global/user_spawner.rs:396
↓ 1 callersFunctionassemble_response_login
(connection_global_world_id: EntityId, user: entity::User)
src/ecs/system/global/user_spawner.rs:308
↓ 1 callersFunctionassemble_response_spawn_me
( connection_global_world_id: EntityId, connection_local_world_id: EntityId, location: &Location,
src/ecs/system/local/user_gateway.rs:218
↓ 1 callersFunctionassemble_shutdown_message
()
src/ecs/system/global/local_world_manager.rs:246
↓ 1 callersFunctionassemble_user_despawn
(connection_local_world_id: EntityId)
src/ecs/system/global/local_world_manager.rs:250
↓ 1 callersFunctionassemble_user_despawned
(spawn: &LocalUserSpawn, location: &Location)
src/ecs/system/local/user_gateway.rs:247
↓ 1 callersFunctionassemble_user_ready_to_connect
(connection_local_world_id: EntityId)
src/ecs/system/global/user_spawner.rs:421
↓ 1 callersFunctionassemble_user_spawn_prepared
( connection_global_world_id: EntityId, connection_local_world_id: EntityId, )
src/ecs/system/local/user_gateway.rs:263
↓ 1 callersFunctionassemble_user_spawned
(connection_global_world_id: EntityId)
src/ecs/system/local/user_gateway.rs:241
↓ 1 callersMethodbegin_migration
(&self)
src/model/migrations.rs:162
↓ 1 callersFunctioncheck_and_handle_post_initialization
( connection_global_world_id: EntityId, account: Account, connection: &GlobalConnection, )
src/ecs/system/global/connection_manager.rs:326
↓ 1 callersFunctioncreate_account
(matches: &ArgMatches, config: &Configuration)
src/bin/almetica.rs:235
↓ 1 callersFunctioncreate_argon2id_config
l = length of hash, m = memory, t = iterations, p = number of lanes
src/crypt/password_hash.rs:46
↓ 1 callersMethodcreate_database
(&self)
src/model/migrations.rs:102
↓ 1 callersMethodcreate_migration_table
(&self)
src/model/migrations.rs:114
↓ 1 callersFunctioncreate_new_user
Creates a new user with default values
src/ecs/system/global/user_manager.rs:430
next →1–100 of 372, ranked by callers