How to Integrate Replit with LiveChat

1import os
2import requests
3from datetime import datetime, timedelta
4from typing import Optional
5
6LOGIN = os.environ["LIVECHAT_LOGIN"]
7API_KEY = os.environ["LIVECHAT_API_KEY"]
8AUTH = (LOGIN, API_KEY)  # Basic Auth tuple
9V2_BASE = "https://api.livechatinc.com/v2"
10
11HEADERS = {
12    "Content-Type": "application/json",
13    "X-API-Version": "2"
14}
15
16def get_chats(date_from: str = None, date_to: str = None,
17             agent_login: str = None, page: int = 1) -> dict:
18    """Fetch chat transcripts with optional filters."""
19    if not date_from:
20        yesterday = (datetime.now() - timedelta(days=1)).strftime("%Y-%m-%d")
21        date_from = yesterday
22    if not date_to:
23        date_to = datetime.now().strftime("%Y-%m-%d")
24
25    params = {
26        "date_from": date_from,
27        "date_to": date_to,
28        "page": page
29    }
30    if agent_login:
31        params["agent"] = agent_login
32
33    response = requests.get(
34        f"{V2_BASE}/chats",
35        params=params,
36        auth=AUTH,
37        headers=HEADERS
38    )
39    response.raise_for_status()
40    return response.json()
41
42def get_chat_by_id(chat_id: str) -> dict:
43    """Get the full transcript for a specific chat."""
44    response = requests.get(
45        f"{V2_BASE}/chats/{chat_id}",
46        auth=AUTH,
47        headers=HEADERS
48    )
49    response.raise_for_status()
50    return response.json()
51
52def get_agents() -> list:
53    """List all agents and their current availability status."""
54    response = requests.get(
55        f"{V2_BASE}/agents",
56        auth=AUTH,
57        headers=HEADERS
58    )
59    response.raise_for_status()
60    return response.json()
61
62def get_chat_stats(date_from: str, date_to: str) -> dict:
63    """Get aggregate chat statistics for a date range."""
64    params = {"date_from": date_from, "date_to": date_to}
65    response = requests.get(
66        f"{V2_BASE}/reports/chats/total_chats",
67        params=params,
68        auth=AUTH,
69        headers=HEADERS
70    )
71    response.raise_for_status()
72    return response.json()
73
74# Example usage
75if __name__ == "__main__":
76    agents = get_agents()
77    print(f"Total agents: {len(agents)}")
78    for agent in agents[:5]:
79        print(f"  {agent.get('login')}: {agent.get('status')}")
80
81    chats = get_chats()
82    total = chats.get('total', 0)
83    print(f"\nChats from yesterday: {total}")
84
85    chat_list = chats.get('chats', [])
86    if chat_list:
87        first_chat = get_chat_by_id(chat_list[0]['id'])
88        messages = first_chat.get('messages', [])
89        print(f"\nFirst chat ({len(messages)} messages):")
90        for msg in messages[:3]:
91            print(f"  [{msg.get('author_name')}]: {msg.get('text', '')[:80]}")

1const express = require('express');
2const axios = require('axios');
3
4const app = express();
5app.use(express.json());
6
7const LOGIN = process.env.LIVECHAT_LOGIN;
8const API_KEY = process.env.LIVECHAT_API_KEY;
9
10// Create axios instance with Basic Auth
11const livechat = axios.create({
12  baseURL: 'https://api.livechatinc.com/v2',
13  auth: { username: LOGIN, password: API_KEY },
14  headers: { 'Content-Type': 'application/json', 'X-API-Version': '2' }
15});
16
17// Get recent chats with customer info
18app.get('/chats', async (req, res) => {
19  const { date_from, date_to, page = 1 } = req.query;
20  try {
21    const params = {
22      date_from: date_from || new Date(Date.now() - 86400000).toISOString().split('T')[0],
23      date_to: date_to || new Date().toISOString().split('T')[0],
24      page: parseInt(page)
25    };
26    const { data } = await livechat.get('/chats', { params });
27    const simplified = (data.chats || []).map(chat => ({
28      id: chat.id,
29      started: chat.started,
30      ended: chat.ended,
31      customerName: chat.visitor?.name,
32      customerEmail: chat.visitor?.email,
33      agentName: chat.agents?.[0]?.display_name,
34      rating: chat.rate,
35      messageCount: chat.messages?.length || 0
36    }));
37    res.json({ total: data.total, chats: simplified });
38  } catch (err) {
39    console.error('Chats error:', err.response?.data || err.message);
40    res.status(500).json({ error: err.message });
41  }
42});
43
44// Get all agents with current status
45app.get('/agents', async (req, res) => {
46  try {
47    const { data } = await livechat.get('/agents');
48    res.json(data);
49  } catch (err) {
50    res.status(500).json({ error: err.message });
51  }
52});
53
54// Get chat statistics for a date range
55app.get('/stats', async (req, res) => {
56  const { date_from, date_to } = req.query;
57  try {
58    const params = {
59      date_from: date_from || new Date(Date.now() - 7 * 86400000).toISOString().split('T')[0],
60      date_to: date_to || new Date().toISOString().split('T')[0]
61    };
62    const [totalChats, responseTime, ratings] = await Promise.all([
63      livechat.get('/reports/chats/total_chats', { params }),
64      livechat.get('/reports/chats/first_response_time', { params }),
65      livechat.get('/reports/chats/ratings', { params })
66    ]);
67    res.json({
68      total: totalChats.data,
69      responseTime: responseTime.data,
70      ratings: ratings.data
71    });
72  } catch (err) {
73    console.error('Stats error:', err.response?.data || err.message);
74    res.status(500).json({ error: err.message });
75  }
76});
77
78app.get('/health', (req, res) => res.json({ status: 'ok' }));
79
80app.listen(3000, '0.0.0.0', () => {
81  console.log('LiveChat integration server running on port 3000');
82});

1from flask import Flask, request, jsonify
2import os
3import hmac
4import hashlib
5
6app = Flask(__name__)
7WEBHOOK_SECRET = os.environ.get("LIVECHAT_WEBHOOK_SECRET", "")
8
9@app.route('/livechat/webhook', methods=['POST'])
10def livechat_webhook():
11    # Optional: verify webhook signature if you set a secret key
12    if WEBHOOK_SECRET:
13        signature = request.headers.get('X-LiveChat-Signature', '')
14        expected = hmac.new(
15            WEBHOOK_SECRET.encode(),
16            request.data,
17            hashlib.sha256
18        ).hexdigest()
19        if not hmac.compare_digest(signature, expected):
20            return jsonify({'error': 'Invalid signature'}), 403
21
22    data = request.get_json(force=True)
23    if not data:
24        return jsonify({'error': 'No data'}), 400
25
26    event_type = data.get('event_type', 'unknown')
27    chat_id = data.get('chat', {}).get('id', 'unknown')
28
29    print(f"LiveChat webhook: {event_type} for chat {chat_id}")
30
31    if event_type == 'chat_ended':
32        visitor = data.get('visitor', {})
33        customer_email = visitor.get('email', '')
34        agent = data.get('agents', [{}])[0]
35        agent_name = agent.get('display_name', 'unknown')
36        print(f"Chat ended: {customer_email} with agent {agent_name}")
37        # Update CRM, send to analytics, etc.
38
39    elif event_type == 'rating_added':
40        rating = data.get('rating', {}).get('score', 0)
41        print(f"Rating received: {rating}/5 for chat {chat_id}")
42        # Log to database, trigger follow-up if low rating
43
44    elif event_type == 'new_chat_started':
45        visitor_name = data.get('visitor', {}).get('name', 'Anonymous')
46        print(f"New chat from: {visitor_name}")
47
48    return jsonify({'status': 'received'}), 200
49
50@app.route('/health', methods=['GET'])
51def health():
52    return jsonify({'status': 'ok'}), 200
53
54if __name__ == '__main__':
55    app.run(host='0.0.0.0', port=3000)