نحوه استخراج پست های رسانه های اجتماعی برای همه کاربران خود با API

import 'dotenv/config';

class AyrshareClient {
    constructor(apiKey) {
        this.apiKey = apiKey;
        this.baseURL = 'https://app.ayrshare.com/api';
        this.defaultHeaders = {
            'Authorization': `Bearer ${this.apiKey}`,
            'Content-Type': 'application/json'
        };
    }

    async makeRequest(endpoint, { method = 'GET', headers = {}, params = {}, path = {}, ...options } = {}) {
        // Replace path parameters in endpoint
        let urlEndpoint = endpoint;
        for (const [key, value] of Object.entries(path)) {
            urlEndpoint = urlEndpoint.replace(`:${key}`, value);
        }
        
        let url = `${this.baseURL}${urlEndpoint}`;

        // Add query parameters to URL if they exist
        const queryParams = new URLSearchParams(params).toString();
        if (queryParams) {
            url = `${url}?${queryParams}`;
        }

        const response = await fetch(url, {
            method,
            headers: {
                ...this.defaultHeaders,
                ...headers
            },
            ...options
        });

        if (!response.ok) {
            throw new Error(`API request failed: ${response.status} ${response.statusText}`);
        }

        return response.json();
    }

    async getAllUserProfiles() {
        try {
            const data = await this.makeRequest('/profiles', { method: 'GET' });
            return data.profiles;
        } catch (error) {
            console.error('Error fetching profiles:', error.message);
            throw error;
        }
    }

    async getPostsForProfile(profileKey) {
        try {
            const data = await this.makeRequest('/history', {
                method: 'GET',
                headers: {
                    'Profile-Key': profileKey
                },
                params: {
                    // Example of how to add query parameters if needed
                    // lastRecords: 10,
                    // platforms: ['twitter', 'facebook'].join(',')
                }
            });
            return data.history;
        } catch (error) {
            console.error(`Error fetching posts for profile: ${profileKey}`, error.message);
            throw error;
        }
    }

    async getAllPosts(profileKeyMap) {
        const profiles = await this.getAllUserProfiles();
        const allPosts = [];

        for (const profile of profiles) {
            // Look up the profile key using the refId
            const profileKey = profileKeyMap[profile.refId];
            
            if (!profileKey) {
                console.warn(`No profile key found for refId: ${profile.refId}`);
                continue;
            }

            const posts = await this.getPostsForProfile(profileKey);
            allPosts.push({
                refId: profile.refId,
                posts: posts
            });
        }

        return allPosts;
    }

    async getPostsForPlatform(platform, profileKey) {
        try {
            const data = await this.makeRequest('/history/:platform', {
                method: 'GET',
                headers: {
                    'Profile-Key': profileKey
                },
                path: {
                    platform: platform
                }
            });
            return data.posts;
        } catch (error) {
            console.error(`Error fetching posts for platform: ${platform}`, error.message);
            throw error;
        }
    }

    async getAllPostsForPlatform(platform, profileKeyMap) {
        const profiles = await this.getAllUserProfiles();
        const allPosts = [];

        for (const profile of profiles) {
            const profileKey = profileKeyMap[profile.refId];
            const posts = await this.getPostsForPlatform(platform, profileKey);
            allPosts.push({
                refId: profile.refId,
                posts: posts
            });
        }

        return allPosts;
    }
}

// Usage Example
async function fetchSocialMediaPosts() {
    const client = new AyrshareClient(process.env.AYRSHARE_API_KEY);

    // This would typically come from your internal database
    const profileKeyMap = {
        'ref123': 'profile_key_123',
        'ref456': 'profile_key_456'
        // ... more mappings
    };

    try {
        const allPosts = await client.getAllPosts(profileKeyMap);

        console.log('Successfully retrieved posts for profiles:', 
            allPosts.map(profile => ({
                refId: profile.refId,
                postCount: profile.posts.length
            }))
        );

        const allPostsForPlatform = await client.getAllPostsForPlatform('bluesky', profileKeyMap);

        console.log('Successfully retrieved posts for platform:', 
            allPostsForPlatform.map(profile => ({
                refId: profile.refId,
                postCount: profile.posts.length
            }))
        );


        return allPosts;
    } catch (error) {
        console.error('Failed to fetch posts:', error);
        throw error;
    }
}

fetchSocialMediaPosts();

    constructor(apiKey) {
        this.apiKey = apiKey;
        this.baseURL = 'https://app.ayrshare.com/api';
        this.defaultHeaders = {
            'Authorization': `Bearer ${this.apiKey}`,
            'Content-Type': 'application/json'
        };
    }

    async makeRequest(endpoint, { method = 'GET', headers = {}, params = {}, path = {}, ...options } = {}) {
        // Replace path parameters in endpoint
        let urlEndpoint = endpoint;
        for (const [key, value] of Object.entries(path)) {
            urlEndpoint = urlEndpoint.replace(`:${key}`, value);
        }
        
        let url = `${this.baseURL}${urlEndpoint}`;

        // Add query parameters to URL if they exist
        const queryParams = new URLSearchParams(params).toString();
        if (queryParams) {
            url = `${url}?${queryParams}`;
        }

        const response = await fetch(url, {
            method,
            headers: {
                ...this.defaultHeaders,
                ...headers
            },
            ...options
        });

        if (!response.ok) {
            throw new Error(`API request failed: ${response.status} ${response.statusText}`);
        }

        return response.json();
    }

    async getAllUserProfiles() {
        try {
            const data = await this.makeRequest('/profiles', { method: 'GET' });
            return data.profiles;
        } catch (error) {
            console.error('Error fetching profiles:', error.message);
            throw error;
        }
    }

    async getPostsForProfile(profileKey) {
        try {
            const data = await this.makeRequest('/history', {
                method: 'GET',
                headers: {
                    'Profile-Key': profileKey
                },
                params: {
                    // Example of how to add query parameters if needed
                    // lastRecords: 10,
                    // platforms: ['twitter', 'facebook'].join(',')
                }
            });
            return data.history;
        } catch (error) {
            console.error(`Error fetching posts for profile: ${profileKey}`, error.message);
            throw error;
        }
    }

    async getAllPosts(profileKeyMap) {
        const profiles = await this.getAllUserProfiles();
        const allPosts = [];

        for (const profile of profiles) {
            // Look up the profile key using the refId
            const profileKey = profileKeyMap[profile.refId];
            
            if (!profileKey) {
                console.warn(`No profile key found for refId: ${profile.refId}`);
                continue;
            }

            const posts = await this.getPostsForProfile(profileKey);
            allPosts.push({
                refId: profile.refId,
                posts: posts
            });
        }

        return allPosts;
    }

    async getPostsForPlatform(platform, profileKey) {
        try {
            const data = await this.makeRequest('/history/:platform', {
                method: 'GET',
                headers: {
                    'Profile-Key': profileKey
                },
                path: {
                    platform: platform
                }
            });
            return data.posts;
        } catch (error) {
            console.error(`Error fetching posts for platform: ${platform}`, error.message);
            throw error;
        }
    }

    async getAllPostsForPlatform(platform, profileKeyMap) {
        const profiles = await this.getAllUserProfiles();
        const allPosts = [];

        for (const profile of profiles) {
            const profileKey = profileKeyMap[profile.refId];

            if (!profileKey) {
                console.warn(`No profile key found for refId: ${profile.refId}`);
                continue;
            }

            const posts = await this.getPostsForPlatform(platform, profileKey);
            allPosts.push({
                refId: profile.refId,
                posts: posts
            });
        }

        return allPosts;
    }

// Usage Example
async function fetchSocialMediaPosts() {
    const client = new AyrshareClient(process.env.AYRSHARE_API_KEY);

    // This would typically come from your internal database
    const profileKeyMap = {
        'ref123': 'profile_key_123',
        'ref456': 'profile_key_456'
        // ... more mappings
    };

    try {
        const allPosts = await client.getAllPosts(profileKeyMap);

        console.log('Successfully retrieved posts for profiles:', 
            allPosts.map(profile => ({
                refId: profile.refId,
                postCount: profile.posts.length
            }))
        );

        const allPostsForPlatform = await client.getAllPostsForPlatform('bluesky', profileKeyMap);

        console.log('Successfully retrieved posts for platform:', 
            allPostsForPlatform.map(profile => ({
                refId: profile.refId,
                postCount: profile.posts.length
            }))
        );


        return [allPosts, allPostsForPlatform];
    } catch (error) {
        console.error('Failed to fetch posts:', error);
        throw error;
    }
}

fetchSocialMediaPosts();