ihrm/recruitment/views/linkedin.py

from django.contrib import messages 
import re
from django.shortcuts import redirect, render
from django.urls import reverse
import requests
import json
import os
import logging
logger = logging.getLogger(__name__)
from django.utils.translation import gettext_lazy as _
from django.http import HttpResponse, JsonResponse
from horilla_views.cbv_methods import login_required, permission_required
from recruitment.models import LinkedInAccount, Recruitment
import json
import requests
from django.conf import settings
from bs4 import BeautifulSoup

@login_required
@permission_required("recruitment.update_linkedinaccount")
def update_isactive_linkedin(request, obj_id):
    """
    htmx function to update is active field in LinkedInAccount.
    Args:
    - is_active: Boolean value representing the state of LinkedInAccount,
    - obj_id: Id of LinkedInAccount object.
    """
    is_active = request.POST.get("is_active")
    linkedin_account = LinkedInAccount.objects.get(id=obj_id)
    if is_active == "on":
        linkedin_account.is_active = True
        messages.success(request, _("LinkedIn Account activated successfully."))
    else:
        linkedin_account.is_active = False
        messages.success(request, _("LinkedIn Account deactivated successfully."))
    linkedin_account.save()

    return HttpResponse("<script>$('#reloadMessagesButton').click();</script>")

@login_required
@permission_required("recruitment.delete_linkedinaccount")
def delete_linkedin_account(request, pk,return_redirect=True):
    """
    Delete Linkedin account
    """
    try:
        if return_redirect:
            LinkedInAccount.objects.get(id=pk).delete()
            messages.success(request, "Linkedin data deleted")
            return redirect(reverse("linkedin-setting-list"))
    except Exception as e:
        logger(e)
        messages.error(request, "Something went wrong")

@login_required
def check_linkedin(request):
    import requests
    url = 'https://www.linkedin.com/oauth/v2/userinfo'
    data = {
        'grant_type': 'authorization_code',
        'code': 'AQXepuwNjedxqn6A7XE75IBHWGdCGeuWqB8ZmhlA9oFbKIHtSBzsKaPwJ5uw4opHURUAwNbi3asSUkJvjmR57BNqgK-Snw_2nUhuRp_S3cTRtFcCrE4JZKIZpy_aTWokL3tr1BFGu0zfgzK1uSU5zYClUeQ4j4bTNkCmvjVAQ8T_4T9JdJ8MZg8m84tMMsuvbniMXOGrdURJXJsmBHckyFnaFD0Mp9Fahl85BGYXqtm0czifPhOJH3TuP2GQQb8fQoNH9rDWcXoNW9D0Jchkv-gs_7_p3cz_U0Dqa_6g_Qdj-5uGdTjPiZlKZNCjPNOsK28lilGOtybHipJ8kVkhoW_tg774Zg',
        'redirect_uri': 'https://www.linkedin.com/developers/tools/oauth/redirect',
        'client_id': '86bnqwzxrmxdy6',
        'client_secret': 'WPL_AP1.op0BkkK4xDn5ANwP.RuayNw=='
    }

    response = requests.post(url, data=data)
    return JsonResponse (response)

@login_required
def validate_linkedin_token(request,pk):
    linkedin_account = LinkedInAccount.objects.filter(id=pk).first()
    access_token = linkedin_account.api_token
    url = 'https://api.linkedin.com/v2/userinfo'
    headers = {
        'Authorization': f'Bearer {access_token}'
    }
    response = requests.get(url, headers=headers)
    if response.status_code == 200:
        messages.success(request, _("LinkedIn connection success."))
    else:
        messages.success(request, _("LinkedIn connection failed."))
    return HttpResponse("<script>$('#reloadMessagesButton').click();</script>")


def html_to_text(html):
    soup = BeautifulSoup(html, 'html.parser')
    return '\n'.join(p.get_text(strip=True) for p in soup.find_all(['p', 'br']) if p.get_text(strip=True))

@login_required
def post_recruitment_in_linkedin(request, recruitment, linkedin_acc, feed_type="feed", group_id=None):
    site_url = request.build_absolute_uri('/')[:-1]  # Gets the base URL 
    recruitment_url = f'{site_url}/recruitment/application-form?recruitmentId={recruitment.id}'

    payload_dict = {
        "author": f"urn:li:person:{linkedin_acc.sub_id}",
        "lifecycleState": "PUBLISHED",
        "specificContent": {
            "com.linkedin.ugc.ShareContent": {
                "shareCommentary": {
                    "text": html_to_text(recruitment.description)
                },
                "shareMediaCategory": "ARTICLE",
                "media": [
                    {
                        "status": "READY",
                        "description": {
                            "text": recruitment.description
                        },
                        "originalUrl": recruitment_url,
                        "title": {
                            "text": recruitment.title
                        },
                        "thumbnails": [
                            {
                                "url": recruitment_url
                            }
                        ]
                    }
                ]
            }
        },
        "visibility": {
            "com.linkedin.ugc.MemberNetworkVisibility": "PUBLIC" if feed_type == "feed" else "CONTAINER"
        }
    }

    if feed_type == "group" and group_id:
        payload_dict["containerEntity"] = f"urn:li:group:{group_id}"

    url = "https://api.linkedin.com/v2/ugcPosts"
    payload = json.dumps(payload_dict)
    headers = {
        'Authorization': f'Bearer {linkedin_acc.api_token}',
        'Content-Type': 'application/json'
    }
    response = requests.post(url, headers=headers, data=payload)
    if response.status_code == 201:
        response_data = response.json()
        recruitment.linkedin_post_id = response_data.get("id")  # Store post ID
        recruitment.save()
    else:
        recruitment.publish_in_linkedin = False
        recruitment.save()


@login_required
def delete_post(recruitment):
    """ Delete recruitment post from linkedin """
    # Ensure you are using the correct post ID from when you created the post
    linkedin_post_id = recruitment.linkedin_post_id  # e.g., "urn:li:ugcPost:123456789"

    url = f"https://api.linkedin.com/v2/ugcPosts/{linkedin_post_id}"
    headers = {
        'Authorization': f'Bearer {recruitment.linkedin_account_id.api_token}',
        'Content-Type': 'application/json'
    }

    response = requests.delete(url, headers=headers)

    if response.status_code == 204:
        # Successfully deleted
        recruitment.linkedin_post_id = None
        recruitment.save()
        return True
    else:
        return False