import io from 'socket.io-client';

const socket = io('http://localhost:3000', {
  auth: {
    token: 'your-jwt-token'
  }
});

// Listen for timeline notifications
socket.on('notification', (notification) => {
  console.log('New notification:', notification);
});

// Listen for new activities
socket.on('new-activity', (activity) => {
  console.log('New activity:', activity);
});

// Join a channel
socket.emit('join-channel', 'channel-123');

// Listen for new messages
socket.on('new-message', (message) => {
  console.log('New message:', message);
});

// examples/complete-test.js
const { createServer } = require('@budytalk/activity-server');

async function completeTest() {
  // Start server
  const server = await createServer({
    port: 3000,
    jwtSecret: 'test-secret',
    database: { type: 'sqlite', url: './test.db' }
  });
  
  await server.start();
  
  const { userService, socialService, timelineService } = server.getServices();
  
  // Create test users
  const alice = await userService.createUser({
    username: 'alice',
    email: 'alice@test.com',
    password: 'password123',
    displayName: 'Alice Johnson',
    workspaceId: 'test'
  });
  
  const bob = await userService.createUser({
    username: 'bob',
    email: 'bob@test.com',
    password: 'password123',
    displayName: 'Bob Smith',
    workspaceId: 'test'
  });
  
  console.log('✅ Users created');
  
  // Bob follows Alice
  await socialService.followUser(bob.id, alice.id);
  console.log('✅ Bob followed Alice');
  
  // Alice creates a post
  const post = await socialService.createPost({
    userId: alice.id,
    content: 'Hello everyone! Testing the timeline system 🚀',
    postType: 'text',
    workspaceId: 'test',
    hashtags: ['#test', '#timeline'],
    mentions: ['@bob']
  });
  
  console.log('✅ Alice created a post');
  
  // Wait for timeline processing
  await new Promise(resolve => setTimeout(resolve, 1000));
  
  // Check Bob's timeline
  const bobTimeline = await timelineService.getUserTimeline(bob.id, 10, 0);
  console.log(`✅ Bob's timeline has ${bobTimeline.length} posts`);
  
  // Bob reacts to Alice's post
  await socialService.addReaction({
    userId: bob.id,
    type: 'like',
    activityId: post.id
  });
  
  console.log('✅ Bob liked Alice\'s post');
  
  // Bob comments on Alice's post
  await socialService.addComment({
    userId: bob.id,
    activityId: post.id,
    content: 'Great post, Alice! The timeline system works perfectly! 👏',
    mentions: ['@alice']
  });
  
  console.log('✅ Bob commented on Alice\'s post');
  
  // Create a poll
  const pollPost = await socialService.createPost({
    userId: alice.id,
    content: 'Quick poll: What\'s your favorite feature?',
    postType: 'poll',
    workspaceId: 'test',
    poll: {
      question: 'What\'s your favorite feature?',
      options: [
        { text: 'Timeline System' },
        { text: 'Real-time Notifications' },
        { text: 'Reactions' },
        { text: 'Comments' }
      ],
      settings: {
        allowMultipleChoices: false,
        showResults: 'after_vote',
        duration: 24
      }
    }
  });
  
  console.log('✅ Alice created a poll');
  
  // Bob votes on the poll
  const poll = await socialService.getPollById(pollPost.poll.id);
  const timelineOption = poll.options.find(opt => opt.text === 'Timeline System');
  
  await socialService.votePoll({
    userId: bob.id,
    pollId: poll.id,
    optionIds: [timelineOption.id]
  });
  
  console.log('✅ Bob voted on Alice\'s poll');
  
  // Get final timeline
  const finalTimeline = await timelineService.getUserTimeline(bob.id, 20, 0);
  console.log(`📱 Bob's final timeline: ${finalTimeline.length} activities`);
  
  // Get trending posts
  const trending = await timelineService.getTrendingPosts('test', 5, 24);
  console.log(`🔥 Trending posts: ${trending.length} posts`);
  
  console.log('\n🎉 Complete test finished successfully!');
  console.log('🎯 Features tested:');
  console.log('   ✓ User creation and authentication');
  console.log('   ✓ Following system');
  console.log('   ✓ Post creation and timeline updates');
  console.log('   ✓ Reactions and notifications');
  console.log('   ✓ Comments and mentions');
  console.log('   ✓ Polls and voting');
  console.log('   ✓ Trending content');
  
  await server.stop();
}

completeTest().catch(console.error);

// src/index.js
const { createServer } = require('@budytalk/activity-server');

async function startApp() {
  const server = await createServer({
    port: process.env.PORT || 3000,
    jwtSecret: process.env.JWT_SECRET || 'your-secret-key',
    database: {
      type: 'sqlite',
      url: process.env.DATABASE_URL || './data/app.db'
    },
    websocket: {
      enabled: true
    }
  });
  
  await server.start();
  console.log(`🚀 Social app running on port ${server.config.port}`);
}

startApp().catch(console.error);