search

processone / docker-ejabberd

Set of ejabberd Docker images
95 stars 77 forks source link

Failed to start external authentication program #114

Closed jenadiusnicholaus closed 4 months ago

jenadiusnicholaus commented 4 months ago

Hi every, am working on setting up my ejabberd server to user extenal auth and this is the error i am experience, now pls some one help me out.

2024-06-04 13:50:32.893868+03:00 [error] Failed to start external authentication program 'python3 /Users/mac/development/python_project/bC/ejabberd_auth.py' 2024-06-04 13:50:32.894126+03:00 [error] External authentication program failed when calling 'user_exists' for admin@localhost: disconnected

my ejabberd.yml file

###
###              ejabberd configuration file
###
### The parameters used in this configuration file are explained at
###
###       https://docs.ejabberd.im/admin/configuration
###
### The configuration file is written in YAML.
### *******************************************************
### *******           !!! WARNING !!!               *******
### *******     YAML IS INDENTATION SENSITIVE       *******
### ******* MAKE SURE YOU INDENT SECTIONS CORRECTLY *******
### *******************************************************
### Refer to http://en.wikipedia.org/wiki/YAML for the brief description.
###

hosts:
  - localhost

loglevel: info

sql_type: pgsql
sql_server: "localhost"
sql_database: "******"
sql_username: "****"
sql_password: "***"
default_db: sql

auth_method:
  - external
  # - sql
  # - internal
  # - anonymous
extauth_program: python3 /Users/mac/development/python_project/bC/ejabberd_auth.py
extauth_pool_size: 3
auth_use_cache: false

## If you already have certificates, list them here
# certfiles:
#   - /etc/letsencrypt/live/domain.tld/fullchain.pem
#   - /etc/letsencrypt/live/domain.tld/privkey.pem

listen:
  - port: 5222
    ip: "::"
    module: ejabberd_c2s
    max_stanza_size: 262144
    shaper: c2s_shaper
    access: c2s
    starttls_required: true

  - port: 5223
    ip: "::"
    module: ejabberd_c2s
    max_stanza_size: 262144
    shaper: c2s_shaper
    access: c2s
    tls: true

  - port: 5269
    ip: "::"
    module: ejabberd_s2s_in
    max_stanza_size: 524288
    shaper: s2s_shaper

  - port: 5443
    ip: "::"
    module: ejabberd_http
    # tls: true
    request_handlers:
      /admin: ejabberd_web_admin
      /api: mod_http_api
      /bosh: mod_bosh
      /captcha: ejabberd_captcha
      /upload: mod_http_upload
      /ws: ejabberd_http_ws

  - port: 5280
    ip: "::"
    # tls: true
    module: ejabberd_http
    request_handlers:
      /admin: ejabberd_web_admin
      /api: mod_http_api
      /oauth: ejabberd_oauth
      /websocket: ejabberd_http_ws
      /.well-known/acme-challenge: ejabberd_acme

  - port: 3478
    ip: "::"
    transport: udp
    module: ejabberd_stun
    use_turn: true
    ## The server's public IPv4 address:
    # turn_ipv4_address: "203.0.113.3"
    ## The server's public IPv6 address:
    # turn_ipv6_address: "2001:db8::3"
  - port: 1883
    ip: "::"
    module: mod_mqtt
    backlog: 1000

s2s_use_starttls: optional

oauth_expire: 3600
oauth_access: all

acl:
  local:
    user_regexp: ""
  loopback:
    ip:
      - 127.0.0.0/8
      - ::1/128
  apicommands:
    user: admin@localhost
  admin:
    user:
      - admin@localhost

access_rules:
  local:
    allow: local
  c2s:
    deny: blocked
    allow: all
  announce:
    allow: admin
  configure:
    allow: admin
  muc_create:
    allow: local
  pubsub_createnode:
    allow: local
  trusted_network:
    allow: loopback

api_permissions:
  "some playing":
    from:
      - ejabberd_ctl
      - mod_http_api
    who:
      acl: apicommands
    what: "*"

  "console commands":
    from:
      - ejabberd_ctl
    who: all
    what:
      - "*"
      - "!stop"
      - "!start"

  "admin access":
    who:
      access:
        allow:
          - acl: loopback
          - acl: admin
      oauth:
        scope: "ejabberd:admin"
        access:
          allow:
            - acl: loopback
            - acl: admin
    what:
      - "*"
      - "!stop"
      - "!start"
  "public commands":
    who:
      ip: 127.0.0.1/8
    what:
      - status
      - connected_users_number

shaper:
  normal:
    rate: 3000
    burst_size: 20000
  fast: 100000

shaper_rules:
  max_user_sessions: 10
  max_user_offline_messages:
    5000: admin
    100: all
  c2s_shaper:
    none: admin
    normal: all
  s2s_shaper: fast

modules:
  mod_adhoc: {}
  mod_admin_extra: {}
  mod_announce:
    access: announce
  mod_avatar: {}
  mod_blocking: {}
  mod_bosh: {}
  mod_caps: {}
  mod_carboncopy: {}
  mod_client_state: {}
  mod_configure: {}
  mod_disco: {}
  mod_fail2ban: {}
  mod_http_api: {}
  mod_http_upload:
    put_url: https://@HOST@:5443/upload
    custom_headers:
      "Access-Control-Allow-Origin": "https://@HOST@"
      "Access-Control-Allow-Methods": "GET,HEAD,PUT,OPTIONS"
      "Access-Control-Allow-Headers": "Content-Type"
  mod_last: {}
  mod_mam:
    ## Mnesia is limited to 2GB, better to use an SQL backend
    ## For small servers SQLite is a good fit and is very easy
    ## to configure. Uncomment this when you have SQL configured:
    db_type: sql
    assume_mam_usage: true
    default: always
    request_activates_archiving: true
  mod_mqtt: {}
  mod_muc:
    host: "conference.@HOST@"
    access:
      - allow
    access_admin:
      - allow: admin
    access_create: muc_create
    access_persistent: muc_create

    access_mam:
      - allow
    default_room_options:
      mam: true
      allow_change_subj: true
      allow_visitor_status: true
      allow_user_invites: true
      max_users: 200
      persistent: true
  mod_muc_admin: {}
  mod_offline:
    access_max_user_messages: max_user_offline_messages
  mod_ping: {}
  mod_privacy: {}
  mod_private: {}
  mod_proxy65:
    access: local
    max_connections: 5
  mod_pubsub:
    access_createnode: pubsub_createnode
    plugins:
      - flat
      - pep
    force_node_config:
      ## Avoid buggy clients to make their bookmarks public
      storage:bookmarks:
        access_model: whitelist
  mod_push: {}
  mod_push_keepalive: {}
  mod_register:
    ## Only accept registration requests from the "trusted"
    ## network (see access_rules section above).
    ## Think twice before enabling registration from any
    ## address. See the Jabber SPAM Manifesto for details:
    ## https://github.com/ge0rg/jabber-spam-fighting-manifesto
    ip_access: trusted_network
  mod_roster:
    versioning: true
  mod_s2s_dialback: {}
  mod_shared_roster: {}
  mod_stream_mgmt:
    resend_on_timeout: if_offline
  mod_stun_disco: {}
  mod_vcard: {}
  mod_vcard_xupdate: {}
  mod_version:
    show_os: false
### Local Variables:
### mode: yaml
### End:
### vim: set filetype=yaml tabstop=8

my script


# !/usr/bin/env python3
import sys
import logging
from struct import *
# import requests
import os   
import json 
import os
import django

from django.conf import settings

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'bcsettings.settings')

django.setup()
from django.contrib.auth.models import User
from django.contrib.auth import authenticate
from django.contrib.auth.hashers import make_password   

log_file_path = os.path.join(settings.BASE_DIR, 'ejabberd_auth_bridge.log')

sys.stderr = open(log_file_path, 'w')

logging.basicConfig(level=logging.INFO,
                    format='%(asctime)s %(levelname)s %(message)s',
                    filename=log_file_path,
                    filemode='a')

# sys.stderr = open('ejabberd_auth_bridge.log', 'w')
# logging.basicConfig(level=logging.INFO,
#                     format='%(asctime)s %(levelname)s %(message)s',
#                     filename='ejabberd_auth_bridge.log',
#                     filemode='a')

logging.info('extauth script started, waiting for ejabberd requests')

def from_ejabberd():
    input_length = sys.stdin.buffer.read(2)
    logging.info("Bytes read: " + str(len(input_length)))
    logging.info("Input Length: " + str(input_length))
    (size,) = unpack('>h', input_length)
    return sys.stdin.buffer.read(size).split(b':')

def to_ejabberd(bool):
    answer = 0
    if bool:
        answer = 1
    token = pack('>hh', 2, answer)
    sys.stdout.buffer.write(token)
    sys.stdout.flush()

def is_authenticated(username, password):
    user = authenticate(username=username, password=password)
    if user is not None:
        return True
    else:
        return False    

def auth(username, server, password):
    logging.info("Authenticating user: " + username)
    if is_authenticated(username, password):
        logging.info("Authentication successful for user: " + username)
        return True
    else:
        logging.info("Authentication failed for user: " + username)
        return False

def isuser(username, server):
    if User.objects.filter(username=username).exists():
        return True
    else:
        return False

def setpass(username, server, password):
    pass
    # User = get_user_model()
    # try:
    #     user = User.objects.get(username=username)
    #     user.password = make_password(password)
    #     user.save()
    #     return True
    # except User.DoesNotExist:
    #     return False

while True:
    data = from_ejabberd()
    logging.info("Data: " + data)
    success = False
    if data[0] == "auth":
        success = auth(data[1], data[2], data[3])
        logging.info("Auth success: " + str(success))
    elif data[0] == "isuser":
        success = isuser(data[1], data[2])
        logging.info("Isuser success: " + str(success))
    elif data[0] == "setpass":
        success = setpass(data[1], data[2], data[3])
    to_ejabberd(success)
jenadiusnicholaus commented 4 months ago

Guys i managed to fix the issue, the issue does not exists on me anymore.