A simple and scalable javascript library to perform OTP operations. Works in Node, Deno, and Bun runtimes.
- Requires only a single key-value storage
- Almost stateless operation, straightforward client/server logic
- Very easy to implement in server-side rendered applications
npm install @romanzy/otp
yarn add @romanzy/otp
pnpm install @romanzy/otp
bun install @romanzy/otpTo create a storage adapter, implement the OtpStorage interface
export interface OtpStorage {
set(key: string, value: string, ttl: number /* in seconds! */): Promise<void>;
get(key: string): Promise<string | null>;
invalidate(key: string): Promise<void>;
}Or use UnstorageAdapter to support many different backend key-value data stores. The complete list can be found in the official documentation here.
Examples will use the MemoryStorage implementation, which is a simple wrapper around js Map().
Create an instance of OtpService:
import { OtpService, OtpError } from '@romanzy/otp';
import { MemoryStorage } from '@romanzy/otp/storage/MemoryStorage';
type SendArgs = { locale: string };
export const otpService = new OtpService({
storage: new MemoryStorage(),
maxAttempts: 3,
timeToResend: 60 * 1000, // units in milliseconds
timeToSolve: 5 * 60 * 1000, // units in milliseconds
generateSolution: () => '1234',
sendOtp: async (account, solution, args: SendArgs) => {
console.log('sent otp to', account, 'with solution', solution);
// write code to send otp to the user
},
});Issue a token, route POST /otp/issue
try {
const { token, data, error, meta } = await otpService.issue(
body.phone,
undefined, // custom data to attach to otp
{ locale: 'en' } // args passed to sendOtp
);
// redirect to correct page
set.headers['HX-Location'] = `/otp/${token}/`;
} catch (error: unknown) {
// Typed error is returned
if (error instanceof OtpError) {
if (error.message == 'BAD_REQUEST') set.status = 400;
else if (error.message == 'INTERNAL_ERROR') set.status = 500;
}
}Get token information GET /otp/:token/
try {
const { token, data, error, meta } = await otpService.getTokenInformation(
params.token
);
return (
<RootLayout title="Confirm OTP page">
<OtpPage token={token} data={data} meta={meta} error={error}></OtpPage>
</RootLayout>
);
} catch (error: unknown) {
if (error instanceof OtpError) {
if (error.message == 'BAD_REQUEST') set.status = 400;
else if (error.message == 'INTERNAL_ERROR') set.status = 500;
return (
<RootLayout title="Confirm OTP page">
{error.message == 'INTERNAL_ERROR' && (
<div>Internal server error. Cause: {error.cause}</div>
)}
{error.message == 'BAD_REQUEST' && (
<div>Bad request. Cause: {error.cause}</div>
)}
</RootLayout>
);
}
}Please note that all methods of OtpService can throw OtpError. These functions throw when a malicious request is made by the client or when experiencing technical problems with storage. In the following examples, try-catch error handling is omitted for brevity.
Check solution, route POST /otp/:token/check
const { token, data, meta, error } = await otpService.check(
params.token, // token from the client
body.solution // solution from the clent
);
if (!meta.isSolved) {
// set new token on the client
set.headers['HX-Replace-Url'] = `/otp/${token}/`;
// re-render otp form with error message
return (
<OtpForm token={token} data={data} meta={meta} error={error}></OtpForm>
);
}
// proceed to business logic
const { account, customData } = data;Resend a token, route POST /otp/:token/resend
const { token, data, meta, error } = await otpService.resend(params.token, {
locale: 'en',
});
set.headers['HX-Replace-Url'] = `/otp/${token}/`;
return <OtpForm token={token} data={data} meta={meta} error={error}></OtpForm>;All of the functions above return the OtpResult type.
export type OtpResult<Data = unknown> = {
token: string;
data: {
id: string;
account: string;
expiresAt: number;
resendAt: number;
attemptsRemaining: number;
customData: Data;
};
meta: {
isSolved: boolean;
canResend: boolean;
canAttempt: boolean;
isExpired: boolean;
};
error: 'NO_ATTEMPTS_REMAINING' | 'EXPIRED' | 'BAD_SOLUTION' | null;
};To use unstorage datapter do the following
import { OtpService } from '@romanzy/otp';
import { UnstorageAdapter } from '@romanzy/otp/storage/UnstorageAdapter';
import redisDriver from 'unstorage/drivers/redis';
export const otpService = new OtpService({
storage: new UnstorageAdapter(
redisDriver({
// driver options
})
),
...
});Custom implementation of storage can be easily created by implementing OtpStorage interface.
export interface OtpStorage {
/**
* Saves solution to storage
*
* @param ttl time to live, in seconds
* @throws when storage malfunctions
*/
set(key: string, value: string, ttl: number): Promise<void>;
/**
* Returns solution from storage
*
* @returns string when value is found. Null when key does not exist.
* @throws when storage malfunctions
*/
get(key: string): Promise<string | null>;
/**
* Invalidates solution from storage
*
* @throws when storage malfunctions
*/
invalidate(key: string): Promise<void>;
}Serializers define how token value is stringified and parsed. If unspecified, OpenTokenSerializer is used. There are 3 built in options for serializers:
OpenTokenSerializer: All token data will readable by the client, includingcustomData.OpenTokenEncryptedDataSerializer: OnlycustomDataof the token is encrypted, all other information such asexpiryoraccountare visible.EncryptedTokenSerializer: Entire token is encrypted, therefore it can be used in SSR applications. Technically does not provide extra security compared toOpenTokenEncryptedDataSerializer. But it does provide authentication since AES block ciphers are used.
Make sure that the length of the secret is correct. If the secret is string, it must be 8 times smaller then encryption size (196 in this example).
import { EncryptedTokenSerializer } from '@romanzy/otp/serializer/EncryptedTokenSerializer';
export const otpService = new OtpService({
tokenSerializer: new EncryptedTokenSerializer(
'supersecretencryptionkey',
'aes-196-gcm'
),
...
});Or roll your own serializer by implementing TokenSerializer interface.
export interface TokenSerializer {
stringify<Data = unknown>(data: OtpData<Data>): string;
parse<Data = unknown>(token: string): OtpData<Data>;
}import {
numericalSolutionGenerator,
browserDecodeToken,
} from '@romanzy/otp/helpers';
// 6-digit code generator
const generateSolution = numericalSolutionGenerator(6);
// decode token value into data of OtpResult in the browser
// works only with default OpenTokenSerializer for now!
const { account, expiresAt, resendAt, attemptsRemaining } =
browserDecodeToken('...');Available here
See htmx example.
This library operates on the idea of unique tokens and cache keys. Every time a new token is issued, the following data is encoded as base64url:
- unique id
- account (email or phone number)
- number of attempts remaining
- expiration time
- resend time
- any custom data
The generated token string is hashed, and the solution to the OTP is stored in a centralized cache, using the hashed token as a cache key.
This token is then sent to the client to decode and display interactive UI. Or even better, it can be server-side rendered. When the client sends a solution to the server, the server looks up the solution in the cache. If it is correct, it is marked as solved. If the solution is wrong, the server invalidates the previous hash and creates a new one, which is sent back to the client.
I am looking for feedback and potential vulnerabilities in this method of OTP validation.
Security comes from hashing. Since the token is derived from a random ID, account name, issue time, and attempts remaining count, the current token value cannot be guessed by a 3rd party. Every time the token is used, it is invalidated (except when explicitly told to allowReuseOfSolvedToken; more on this later)
The tokens are protected from modification by indexing them in the cache by hashed value (with sha256 as default); the server simply can not find a maliciously modified token in the hash. Since every token is given a small number of attempts, it is unlikely for the 1st party to go around it without entering the correct solution.
The customData field can store arbitrary JSON-encodable information inside the token, allowing the developer to ensure that solved tokens are not used for other purposes.
When issuing a token with allowReuseOfSolvedToken enabled, values for solved tokens in storage are overridden to s constant value S. The next time getTokenInformation is called, it will know that the token is solved.
This library depends on the crypto module. All cryptographic operations are performed using this module.
Always implement some sort of rate limit by IP or account to prevent abuse. Sending text messages costs money, and email spam is terrible for domain-name reputation. Rate-limit both solving and issuing of tokens before using this library.
Validate and normalize the account field before issuing the tokens: trim whitespaces, convert emails to lowercase, remove "+" in phone numbers, use Google's libphonenumber, etc.
Always validate token data when OTP is solved correctly. Grant login/registration to [email protected] only if the token has an account of [email protected]. If not careful, an attacker with the email [email protected] could log in to the account of [email protected] by substituting the solved token before hitting the login API endpoint.
Use at least 6-digit OTP codes, allow no more than 3 attempts, and expire tokens after no more than 5 minutes.
- Better readme, add workflow diagram
- More helper functions
- Client-side react example