diff --git a/config-schema.dhall b/config-schema.dhall
index 36f07d4118cc7261be71c281c3b1d800a9489386..da931fe7d27f0568989c4a5217a4dc0b6646d396 100644
--- a/config-schema.dhall
+++ b/config-schema.dhall
@@ -37,6 +37,7 @@
       , monthly_price : Natural
       , name : Text
       }
+, rev_ai_token : Text
 , server : { host : Text, port : Natural }
 , sgx : Text
 , sip : { app : Text, realm : Text }
diff --git a/config.dhall.sample b/config.dhall.sample
index 59d7f081955a309ec4c1c4645e240ed5cc9b5f42..51a73368110d77646b7c79f2d4a56ba041cd80fd 100644
--- a/config.dhall.sample
+++ b/config.dhall.sample
@@ -80,6 +80,7 @@ in
 	keep_area_codes = ["555"],
 	keep_area_codes_in = { account = "", site_id = "", sip_peer_id = "" },
 	snikket_hosting_api = "",
+	rev_ai_token = "",
 	upstream_domain = "example.net",
 	approved_domains = toMap { `example.com` = Some "customer_id" }
 }
diff --git a/lib/backend_sgx.rb b/lib/backend_sgx.rb
index 496814f6d743d8c7173a9c5db03cecfcf8ccf51a..d66290c84554779581f30f7a89bc838a60dc6cce 100644
--- a/lib/backend_sgx.rb
+++ b/lib/backend_sgx.rb
@@ -14,6 +14,7 @@ class BackendSgx
 		ogm_url Either(String, nil, NotLoaded)
 		fwd Either(CustomerFwd, nil, NotLoaded)
 		transcription_enabled Either(Bool(), NotLoaded)
+		alternate_transcription_enabled Either(Bool(), NotLoaded)
 		registered? Either(IBR, FalseClass, NotLoaded)
 	end
 
diff --git a/lib/bwmsgsv2_repo.rb b/lib/bwmsgsv2_repo.rb
index e59c80a771cc78e95f7cbf175e3556dd2390b501..713ba8609a027f058383262f48339c3310e20f59 100644
--- a/lib/bwmsgsv2_repo.rb
+++ b/lib/bwmsgsv2_repo.rb
@@ -8,6 +8,7 @@ require_relative "trivial_backend_sgx_repo"
 
 class Bwmsgsv2Repo
 	VOICEMAIL_TRANSCRIPTION_DISABLED = 0
+	VOICEMAIL_ALT_TRANSCRIPTION = 1
 
 	def initialize(
 		jid: CONFIG[:sgx],
@@ -23,11 +24,12 @@ class Bwmsgsv2Repo
 
 	def get(customer_id)
 		sgx = @trivial_repo.get(customer_id)
-		fetch_raw(sgx.from_jid).then do |(((ogm_url, fwd_time, fwd), trans_d), reg)|
+		fetch_raw(sgx.from_jid).then do |(((ogm_url, fwd_time, fwd), flags), reg)|
 			sgx.with(
 				ogm_url: ogm_url,
 				fwd: CustomerFwd.for(uri: fwd, timeout: fwd_time),
-				transcription_enabled: !trans_d,
+				transcription_enabled: !flags[VOICEMAIL_TRANSCRIPTION_DISABLED],
+				alternate_transcription_enabled: flags[VOICEMAIL_ALT_TRANSCRIPTION],
 				registered?: reg
 			)
 		end
@@ -80,9 +82,15 @@ protected
 				"catapult_fwd_timeout-#{from_jid}",
 				("catapult_fwd-#{tel}" if tel)
 			].compact),
-			@redis.getbit(
-				"catapult_settings_flags-#{from_jid}", VOICEMAIL_TRANSCRIPTION_DISABLED
-			).then { |x| x == 1 }
+			unpack_flags(from_jid)
 		])
 	end
+
+	def unpack_flags(from_jid)
+		@redis.bitfield(
+			"catapult_settings_flags-#{from_jid}",
+			"GET", "u1", VOICEMAIL_TRANSCRIPTION_DISABLED,
+			"GET", "u1", VOICEMAIL_ALT_TRANSCRIPTION
+		).then { |arr| arr.map { |x| x.to_i == 1 } }
+	end
 end
diff --git a/lib/customer.rb b/lib/customer.rb
index 9ce9e7f68d97db0c1d72192cf74d23b3404171b8..13845701376d3ee9e3d94a30c3b0f2a96fc11229 100644
--- a/lib/customer.rb
+++ b/lib/customer.rb
@@ -27,7 +27,7 @@ class Customer
 	               :message_limit, :auto_top_up_amount, :monthly_overage_limit,
 	               :monthly_price, :save_plan!
 	def_delegators :@sgx, :deregister!, :register!, :registered?, :set_ogm_url,
-	               :fwd, :transcription_enabled
+	               :fwd, :transcription_enabled, :alternate_transcription_enabled
 	def_delegators :@usage, :usage_report, :message_usage, :incr_message_usage
 	def_delegators :@financials, :payment_methods, :btc_addresses,
 	               :add_btc_address, :declines, :mark_decline,
diff --git a/lib/rev_ai.rb b/lib/rev_ai.rb
new file mode 100644
index 0000000000000000000000000000000000000000..5964c032ef7a4832df79dd9864ceba7ebdb014fc
--- /dev/null
+++ b/lib/rev_ai.rb
@@ -0,0 +1,70 @@
+# frozen_string_literal: true
+
+require "em-http"
+require "em_promise"
+require "json"
+
+class RevAi
+	def initialize(token: CONFIG[:rev_ai_token])
+		@token = token
+	end
+
+	def stt(language, media_url, callback_url, **kwargs)
+		req(
+			:post,
+			"https://api.rev.ai/speechtotext/v1/jobs",
+			metadata: { media_url: media_url }.merge(kwargs).to_json,
+			source_config: { url: media_url },
+			notification_config: { url: callback_url },
+			remove_disfluencies: language == "en",
+			skip_diarization: true,
+			language: language
+		)
+	end
+
+	def stt_result(job)
+		job = job["job"]
+		req(
+			:get,
+			"https://api.rev.ai/speechtotext/v1/jobs/#{job['id']}/transcript",
+			accept: "text/plain"
+		).then do |res|
+			text = res.response.split("    ", 3)[2].strip
+			job.merge("text" => text, "metadata" => JSON.parse(job["metadata"]))
+		end
+	end
+
+	def language_id(media_url, callback_url, **kwargs)
+		req(
+			:post,
+			"https://api.rev.ai/languageid/v1/jobs",
+			metadata: { media_url: media_url }.merge(kwargs).to_json,
+			source_config: { url: media_url },
+			notification_config: { url: callback_url }
+		)
+	end
+
+	def language_id_result(job)
+		job = job["job"]
+		req(
+			:get,
+			"https://api.rev.ai/languageid/v1/jobs/#{job['id']}/result"
+		).then do |res|
+			json = JSON.parse(res.response)
+			job.merge(json).merge("metadata" => JSON.parse(job["metadata"]))
+		end
+	end
+
+	def req(m, url, accept: nil, **kwargs)
+		EM::HttpRequest.new(
+			url, tls: { verify_peer: true }
+		).public_send(
+			"a#{m}",
+			head: {
+				"Authorization" => "Bearer #{@token}",
+				"Content-Type" => "application/json",
+				"Accept" => accept
+			}, body: kwargs.to_json
+		)
+	end
+end
diff --git a/lib/trivial_backend_sgx_repo.rb b/lib/trivial_backend_sgx_repo.rb
index dedfe4dd54f63d4ef9e196733a4f4c40e1b0f456..e540f9723517a3263328831091570b2c440ace1e 100644
--- a/lib/trivial_backend_sgx_repo.rb
+++ b/lib/trivial_backend_sgx_repo.rb
@@ -16,12 +16,13 @@ class TrivialBackendSgxRepo
 
 	def get(customer_id)
 		BackendSgx.new(
-			jid: @jid,
-			creds: @creds,
+			jid: @jid, creds: @creds,
 			from_jid: Blather::JID.new("customer_#{customer_id}", @component_jid),
 			ogm_url: NotLoaded.new(:ogm_url),
 			fwd: NotLoaded.new(:fwd_timeout),
 			transcription_enabled: NotLoaded.new(:transcription_enabled),
+			alternate_transcription_enabled:
+				NotLoaded.new(:alternate_transcription_enabled),
 			registered?: NotLoaded.new(:registered?)
 		)
 	end
diff --git a/test/test_helper.rb b/test/test_helper.rb
index c4f2b69a604cb6f147d17f660dd65c7fe2eca17f..2ed5db53f6e59014b17ff0fc43c1ab863de844c9 100644
--- a/test/test_helper.rb
+++ b/test/test_helper.rb
@@ -205,6 +205,18 @@ class FakeRedis
 		get(key).then { |v| v.to_i.to_s(2)[bit].to_i }
 	end
 
+	def bitfield(key, *ops)
+		get(key).then do |v|
+			bits = v.to_i.to_s(2)
+			ops.each_slice(3).map do |(op, encoding, offset)|
+				raise "unsupported bitfield op" unless op == "GET"
+				raise "unsupported bitfield op" unless encoding == "u1"
+
+				bits[offset].to_i
+			end
+		end
+	end
+
 	def hget(key, field)
 		@values.dig(key, field)
 	end
diff --git a/web.rb b/web.rb
index f8051cd60c485b0ed44defafa0cf7be2f1ec4a4f..3281e477780006da6dbf55c4e556f982d38fc4e2 100644
--- a/web.rb
+++ b/web.rb
@@ -11,6 +11,7 @@ require "sentry-ruby"
 require_relative "lib/call_attempt_repo"
 require_relative "lib/cdr"
 require_relative "lib/oob"
+require_relative "lib/rev_ai"
 require_relative "lib/roda_capture"
 require_relative "lib/roda_em_promise"
 require_relative "lib/rack_fiber"
@@ -109,6 +110,10 @@ class Web < Roda
 		opts[:call_attempt_repo] || CallAttemptRepo.new
 	end
 
+	def rev_ai
+		RevAi.new
+	end
+
 	TEL_CANDIDATES = {
 		"Restricted" => "14",
 		"anonymous" => "15",
@@ -135,8 +140,11 @@ class Web < Roda
 		)
 	end
 
-	def inbound_calls_path(suffix, customer_id=nil)
-		["/inbound/calls/#{params['callId']}", suffix].compact.join("/") +
+	def inbound_calls_path(suffix, customer_id=nil, call_id: nil)
+		[
+			"/inbound/calls/#{call_id || params['callId']}",
+			suffix
+		].compact.join("/") +
 			(customer_id ? "?customer_id=#{customer_id}" : "")
 	end
 
@@ -158,6 +166,19 @@ class Web < Roda
 		raise $! unless $!.response_code.to_s == "404"
 	end
 
+	def do_alternate_transcription(customer, call_id)
+		return unless customer.alternate_transcription_enabled
+
+		rev_ai.language_id(
+			jmp_media_url,
+			url(inbound_calls_path(
+				"voicemail/rev_ai/language_id", call_id: call_id
+			)),
+			from_jid: from_jid,
+			customer_id: customer.customer_id
+		)
+	end
+
 	route do |r|
 		r.on "inbound" do
 			r.on "calls" do
@@ -204,7 +225,11 @@ class Web < Roda
 								"https://jmp.chat"
 							)
 
-							customer_repo.find_by_tel(params["to"]).then do |customer|
+							customer_repo(
+								sgx_repo: Bwmsgsv2Repo.new
+							).find_by_tel(params["to"]).then do |customer|
+								do_alternate_transcription(customer, call_id)
+
 								m = Blather::Stanza::Message.new
 								m.chat_state = nil
 								m.from = from_jid
@@ -236,6 +261,39 @@ class Web < Roda
 							end
 						end
 
+						r.on "rev_ai" do
+							r.post "language_id" do
+								rev_ai.language_id_result(params).then do |result|
+									rev_ai.stt(
+										result["top_language"],
+										result.dig("metadata", "media_url"),
+										url(inbound_calls_path(
+											"voicemail/rev_ai/transcription",
+											call_id: call_id
+										)),
+										**result["metadata"].transform_keys(&:to_sym)
+									).then { "OK" }
+								end
+							end
+
+							r.post "transcription" do
+								rev_ai.stt_result(params).then do |result|
+									customer_repo.find(
+										result.dig("metadata", "customer_id")
+									).then do |customer|
+										m = Blather::Stanza::Message.new
+										m.chat_state = nil
+										m.from = result.dig("metadata", "from_jid")
+										m.subject = "Voicemail Transcription"
+										m.body = "Alternate Transcription: #{result['text']}"
+										customer.stanza_to(m)
+
+										"OK"
+									end
+								end
+							end
+						end
+
 						r.post do
 							customer_repo(sgx_repo: Bwmsgsv2Repo.new)
 								.find_by_tel(params["to"])