import { FIXServer, fixutil } from 'fixio'

const server = new FIXServer({
  port: 9878,
  host: 'localhost'
})

// Subscribe to incoming messages
server.fixIn$.subscribe(fix => {
  console.log('Received:', fixutil.convertToJSON(fix))
})

// Subscribe to outgoing messages
server.fixOut$.subscribe(fix => {
  console.log('Sent:', fixutil.convertToJSON(fix))
})

// Handle errors
server.error$.subscribe(error => {
  console.error('Server error:', error)
})

// Start listening
server.listen()
console.log('FIX Server listening on port 9878')

import { FIXClient, fixutil } from 'fixio'

const client = new FIXClient(
  'FIX.4.4',
  'CLIENT_ID',
  'SERVER_ID',
  {}
)

// Connect to server
client.connect(9878, 'localhost')

// Subscribe to connection events
client.logon$.subscribe(() => {
  console.log('Logged on successfully')
  
  // Send a test request
  client.send({
    MsgType: 'D', // New Order Single
    ClOrdID: '12345',
    Symbol: 'EURUSD',
    Side: '1', // Buy
    OrderQty: '1000000',
    OrdType: '2', // Limit
    Price: '1.1850'
  })
})

// Subscribe to incoming messages
client.fixIn$.subscribe(fix => {
  console.log('Received:', fixutil.convertToJSON(fix))
})

// Subscribe to disconnect events
client.close$.subscribe(() => {
  console.log('Connection closed')
})

// Handle errors
client.error$.subscribe(error => {
  console.error('Client error:', error)
})

{
  port: number          // TCP port to listen on
  host?: string         // Host address (default: '0.0.0.0')
  protocol?: string     // FIX protocol version (default: 'FIX.4.4')
}

new FIXClient(
  protocol: string,        // e.g., 'FIX.4.4'
  senderCompId: string,    // Your company ID
  targetCompId: string,    // Target company ID
  options: object          // Additional options
)

// Convert FIX string to JSON
fixutil.convertToJSON(fixString: string): object

// Convert FIX string to Map
fixutil.convertToMap(fixString: string): Map<string, string>

// Convert object to FIX string
fixutil.convertToFIX(message: object): string

// Generate UTC timestamp
fixutil.getUTCTimeStamp(date?: Date): string

// Calculate checksum
fixutil.getChecksum(message: string): string

// Convert field names to FIX tags
fixutil.convertFieldsToTags(message: object): object

// Sessions are automatically restored on reconnection
// Log files: ./logs/{SenderCompID}_{TargetCompID}.log

// Send custom FIX messages
client.send({
  MsgType: '8',  // Execution Report
  OrderID: '98765',
  ExecID: 'exec123',
  ExecType: '0',  // New
  OrdStatus: '0', // New
  Symbol: 'GBPUSD',
  Side: '2',      // Sell
  OrderQty: '500000',
  LastQty: '0',
  LastPx: '0',
  LeavesQty: '500000',
  CumQty: '0'
})

client.close$.subscribe(() => {
  console.log('Disconnected, reconnecting in 5 seconds...')
  setTimeout(() => {
    client.connect(9878, 'localhost')
    client.logon()
  }, 5000)
})

const server = new FIXServer({ port: 9878 })

server.logon$.subscribe(({ senderCompId, targetCompId }) => {
  console.log(`Client connected: ${senderCompId} -> ${targetCompId}`)
})

// Broadcast message to all clients
server.getClients().forEach(client => {
  client.send({
    MsgType: '0', // Heartbeat
    // ... other fields
  })
})