A bot framework for
Pixel Worlds

pixel-worlds/
├── src/
│   ├── index.ts                 # Entry point
│   ├── config.ts                # App configuration
│   ├── types/index.ts           # Shared types & enums
│   ├── core/
│   │   ├── session.ts           # Auth + session bootstrap
│   │   ├── bot.ts               # TCP client, packet I/O, actions
│   │   └── world.ts             # World deserialization + tile queries
│   ├── clients/
│   │   ├── playfab_client.ts    # PlayFab REST (Steam/Android/Email)
│   │   └── socialfirst_client.ts  # SocialFirst token exchange
│   └── utils/
│       ├── packets.ts           # BSON packet builders
│       ├── pathfinder.ts        # A* pathfinding
│       ├── logger.ts            # Namespaced terminal logger
│       ├── fetch_with_retry.ts  # HTTP + SOCKS5 + retry
│       ├── conqurent_queue.ts   # Concurrency-limited task queue
│       ├── receive_buffer.ts    # TCP stream reassembly
│       └── zstd_service.ts      # Zstandard decompression
├── tsconfig.json
└── package.json

# Concurrency
THREADS=5

# Steam login
STEAM_ACCOUNT=your_username
STEAM_PASSWORD=your_password

# Android login
ANDROID_DEVICE_ID=

# Email login
PW_EMAIL=you@example.com
PW_EMAIL_PASSWORD=your_password

# API
SF_API_KEY=your_key

# Optional SOCKS5 proxy
PROXY_URL=socks5://127.0.0.1:1080

import { Config } from './types';

export const CONFIG: Config = {
    threads:        Number(process.env.THREADS ?? 1),
    steam_account:  process.env.STEAM_ACCOUNT  ?? '',
    steam_password: process.env.STEAM_PASSWORD ?? '',
    android_device_id: process.env.ANDROID_DEVICE_ID ?? '',
    email:          process.env.PW_EMAIL          ?? '',
    email_password: process.env.PW_EMAIL_PASSWORD ?? '',
    user_agent:     'UnityPlayer/6000.3.11f1 ...',
    unity_version:  '6000.3.11f1',
    sf_api_key:     process.env.SF_API_KEY ?? '',
    proxy_url:      process.env.PROXY_URL,
    urls: { /* PlayFab + SocialFirst endpoints */ },
};

import { PixelWorldsSession } from './core/session';
import { CONFIG } from './config';

const session = new PixelWorldsSession(CONFIG);

// Returns { device_id, sf_token }
const result = await session.start('android');
// or 'steam' | 'email'

interface Tile {
    fore_id: number;       // foreground block ID (0 = air)
    back_id: number;       // background block ID
    pos: { x: number; y: number };
    extra?: WorldItem;    // interactive item on this tile (if any)
}

enum BotStatus {
    AUTHENTICATING  = "authenticating",
    AUTH_FAILED     = "auth_failed",
    OFFLINE         = "offline",
    ONLINE          = "online",
    MENU_READY      = "menu_ready",
    AWAITING_READY  = "awaiting_ready",
    IN_WORLD        = "in_world",
    REDIRECTING     = "redirecting",
}

enum NetStatus {
    NO_SOCKET, IDLE, CONNECTING, CONNECTED, DISCONNECTED
}

type Login_Type = 'steam' | 'android' | 'email';
type Log_Level_Key = 'debug' | 'info' | 'warn' | 'error' | 'silent';

interface Position    { x: number; y: number }

interface Tile {
    fore_id: number;  back_id: number;
    pos: Position;    extra?: WorldItem;
}

interface WorldItem {
    class: string;   item_id: number;
    block_type: number;
    pos: Position;   data: Record<string, any>;
}

interface Collectable {
    collectable_id: number;  block_type: number;
    amount: number;          inventory_type: number;
    pos_x: number;           pos_y: number;
    is_gem: boolean;         gem_type: number;
}

import { CONFIG } from './config';
import { PixelWorldsSession } from './core/session';
import { Bot } from './core/bot';

const session = new PixelWorldsSession(CONFIG);
const { sf_token } = await session.start('android');

const bot = new Bot();
bot.set_credentials(sf_token);

// Optional: route through SOCKS5 proxy
// bot.set_proxy('127.0.0.1', 1080);

bot.on('status:in_world', async (b) => {
    console.log(`Entered world: ${b.world.name}`);

    // Walk to tile (10, 30) via A* pathfinding
    await b.walk_to_map(10, 30);

    // Punch tile to the right
    await b.manual_punch(1, 0);

    // Place a dirt block above
    await b.manual_place(0, -1, 2);

    // Chat
    await b.send_world_chat('Hello!');

    // Read collectables
    const gems = b.world.gem_collectables;
    console.log(`Gems: ${gems.length}`);

    // Find all tiles with block ID 8 (e.g. lava)
    const positions = b.world.find_by_fore(8);

    b.stop();
});

await bot.connect('63.176.210.142');