Аутентификация Node.js Asterisk SIP-заголовки UDP

Авторизация - это заголовок, и все заголовки должны появляться до появления \r\n\r\n (пустая строка)

Обычно авторизацию помещают непосредственно перед заголовком Content-Length. Только с \r\n до и после.

После \r\n\r\n у вас будет тело (если длина содержимого указывает один) или новое SIP-сообщение.

ОБНОВЛЯТЬ: Вот rfc3261 Раздел 20.7, чтобы было понятно, что авторизация — это SIP-заголовок:

20.7 Авторизация

Поле заголовка Authorization содержит учетные данные для аутентификации. UA. Раздел 22.2 описывает использование Разрешения. поле заголовка, а раздел 22.4 описывает синтаксис и семантику при использовании HTTP-аутентификации.

Ваш второй РЕГИСТР должен быть таким:

REGISTER sip:ASTERISKIP:ASTERISKPORT SIP/2.0
Via: SIP/2.0/UDP 192.168.1.2:6111;branch=z9hG4bK30130523
From: <sip:USERNAME@ASTERISKIP>;tag=z9hG4bK30130523
To: <sip:USERNAME@ASTERISKIP>
Call-ID: [email protected]
CSeq: 1 REGISTER
Contact: <sip:[email protected]:6111>
Max-Forwards: 70
Expires: 3600
User-Agent: Node.js SIP Library
Authorization: Digest username = "Tim", realm = "asterisk", nonce = "120ef084", uri = "sip:ASTERISKIP:ASTERISKPORT", response = "e6a25e09e1bb2099436cf10526d955e0"
Content-Length: 0

ОБНОВЛЕНИЕ 2:

Вам действительно следует определить имя пользователя в нижнем регистре как на вашем сервере (когда вы создаете пароль), так и на клиенте, когда вы настраиваете имя пользователя. Довольно часто возникают проблемы с регистром в программном обеспечении HTTP или SIP. Имя пользователя обычно нечувствительно к регистру, поэтому использование Tim приведет к ошибке, если звездочка считает его строчным.

Чтобы проверить ваш ответ md5, проще всего вычислить строку с помощью инструмента md5sum:

$> echo -n "Tim:asterisk:secret" | md5sum
d86544eb768e7936519f727599d51fbb

$> echo -n "REGISTER:sip:ASTERISK_IP:6111" | md5sum
0a1fc837871b52dfe5c7d9a009079265

$> echo -n "d86544eb768e7936519f727599d51fbb:5b4af6d3:0a1fc837871b52dfe5c7d9a009079265" | md5sum
504804156ca15812da67ea5439a9ea00

Затем проверьте, является ли это результатом вашего кода! Я не могу этого сделать, потому что ты спрятал свои настоящие ценности.

Вы можете попробовать с «Тим» или «Тим», чтобы увидеть разницу.

ОБНОВЛЕНИЕ 3:

Я проверил ваш код и исправил несколько вещей:

• Я создаю заголовок Call-Id, который хранится поверх нового REGISTER.
• Я использую возрастающую CSeq для каждого нового РЕГИСТРА.
• Небольшая модификация для использования «домена» вместо «IP» (для моей собственной тестовой цели)
• Я также удалил лишний \r\n в конце второго РЕГИСТРА

Если этого не сделать, сервер может определить это как атаку. Мой собственный сервер (kamailio) отклонял запрос с информацией об истечении срока действия.

Этот код работает для пользователя sip.antisip.com и «stackoverflow» с паролем «WuZkA6T@sQ8W». Я очень скоро удалю этого пользователя из своей службы. Но вы можете убедиться, что они работают.

const dgram = require("dgram");
const crypto = require("crypto");

const asteriskDOMAIN = "sip.antisip.com";
const asteriskIP = "94.23.17.185";
const asteriskPort = 5060;
const clientIP = "192.168.1.9";
const clientPort = 6111;
const username = "stackoverflow";
const password = "WuZkA6T@sQ8W";
let callId;
let cseq = 1;

// Create a UDP socket
const socket = dgram.createSocket("udp4");

// Generate a random branch identifier for the Via header
const generateBranch = () => {
  const branchId = Math.floor(Math.random() * 10000000000000);
  return `z9hG4bK${branchId}X2`;
};

const generateCallid = () => {
  const branchId = Math.floor(Math.random() * 10000000000000);
  return `${branchId}`;
};

// Generate Digest response
function generateDigestResponse(username, password, realm, nonce, method, uri) {
  const ha1 = crypto.createHash("md5")
    .update(`${username}:${realm}:${password}`)
    .digest("hex");

  const ha2 = crypto.createHash("md5")
    .update(`${method}:${uri}`)
    .digest("hex");

  const response = crypto.createHash("md5")
    .update(`${ha1}:${nonce}:${ha2}`)
    .digest("hex");
  return response;
}

// SIP REGISTER request
const generateRegisterRequest = (branch, withAuth = false, realm = "", nonce = "") => {
  let request = `REGISTER sip:${asteriskDOMAIN}:${asteriskPort} SIP/2.0\r\n`
    + `Via: SIP/2.0/UDP ${clientIP}:${clientPort};branch=${branch}\r\n`
    + `From: <sip:${username}@${asteriskDOMAIN}>;tag=${branch}\r\n`
    + `To: <sip:${username}@${asteriskDOMAIN}>\r\n`
    + `Call-ID: ${callId}@${clientIP}\r\n`
    + `CSeq: ${cseq} REGISTER\r\n`
    + `Contact: <sip:${username}@${clientIP}:${clientPort}>\r\n`
    + "Max-Forwards: 70\r\n"
    + "Expires: 3600\r\n"
    + "User-Agent: Node.js SIP Library\r\n";

  cseq += 1;

  if (withAuth && realm && nonce) {
    const digestResponse = generateDigestResponse(username, password, realm, nonce, "REGISTER", `sip:${asteriskDOMAIN}:${asteriskPort}`);
    request += "Authorization: Digest "
      + `username = "${username}", realm = "${realm}", `
      + `nonce = "${nonce}", uri = "sip:${asteriskDOMAIN}:${asteriskPort}", `
      + `response = "${digestResponse}"\r\n`;
  }

  request += "Content-Length: 0\r\n\r\n";

  return request;
};

// Send the REGISTER request
const sendRegisterRequest = (request) => {
  socket.send(request, 0, request.length, asteriskPort, asteriskIP, (error) => {
    if (error) {
      console.error("Error sending UDP packet:", error);
    } else {
      console.info("REGISTER request sent successfully.");
    }
  });
};

let realm = "";
let nonce = "";

// Listen for incoming responses
socket.on("message", (message) => {
  const response = message.toString();
  console.info("Received response:", response);

  if (response.startsWith("SIP/2.0 200 OK")) {
    console.info("Registration successful.");
    // Do further processing or initiate calls here
  } else if (response.startsWith("SIP/2.0 401 Unauthorized")) {
    const authenticateHeader = response.match(/WWW-Authenticate:.*realm = "([^"]+)".*nonce = "([^"]+)"/i);
    if (authenticateHeader) {
      realm = authenticateHeader[1];
      nonce = authenticateHeader[2];
      console.info("Received realm:", realm);
      console.info("Received nonce:", nonce);

      // Generate Digest response and proceed with registration
      const branch = generateBranch();
      const registerRequestWithAuth = generateRegisterRequest(branch, true, realm, nonce);

      console.info("Sending REGISTER request with authentication:");
      console.info(registerRequestWithAuth);
      // Send the REGISTER request with authentication
      sendRegisterRequest(`${registerRequestWithAuth}`);
    }
  }
});

// Bind the socket to the client's port and IP
socket.bind(clientPort, clientIP, () => {
  console.info("Socket bound successfully.");

  // Generate branch identifier for the initial REGISTER request
  const branch = generateBranch();
  callId = generateCallid();
  const registerRequest = generateRegisterRequest(branch);

  // Send the initial REGISTER request
  sendRegisterRequest(registerRequest);
});