Compare commits
8 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 0dbd81d1cc | |||
| f979789c11 | |||
| 498d7d31c4 | |||
| e58f05619e | |||
| 992b9349b3 | |||
| 1f4a1fb90f | |||
| c7fae1ad1d | |||
| 37bcb6a6d2 |
461
otp.c
461
otp.c
@@ -39,29 +39,20 @@ static const int base64_decode_table[256] = {
|
|||||||
#define MAX_LINE_LENGTH 1024
|
#define MAX_LINE_LENGTH 1024
|
||||||
#define MAX_HASH_LENGTH 65
|
#define MAX_HASH_LENGTH 65
|
||||||
#define PROGRESS_UPDATE_INTERVAL (64 * 1024 * 1024) // 64MB intervals
|
#define PROGRESS_UPDATE_INTERVAL (64 * 1024 * 1024) // 64MB intervals
|
||||||
#define PADS_DIR "pads"
|
#define DEFAULT_PADS_DIR "pads"
|
||||||
#define FILES_DIR "files"
|
#define FILES_DIR "files"
|
||||||
#define MAX_ENTROPY_BUFFER 32768 // 32KB entropy buffer
|
#define MAX_ENTROPY_BUFFER 32768 // 32KB entropy buffer
|
||||||
|
|
||||||
// USB Pad structure for external drive detection
|
// Global variable for current pads directory (can be local or OTP thumb drive)
|
||||||
struct USBPadInfo {
|
static char current_pads_dir[512] = DEFAULT_PADS_DIR;
|
||||||
char chksum[65]; // 64-char checksum + null terminator
|
|
||||||
char pad_path[1024]; // Full path to .pad file
|
|
||||||
char state_path[1024]; // Full path to .state file
|
|
||||||
char mount_point[1024]; // USB mount point for display
|
|
||||||
uint64_t state_offset; // Current state offset
|
|
||||||
};
|
|
||||||
|
|
||||||
// Function prototypes
|
// Function prototypes
|
||||||
int main(int argc, char* argv[]);
|
int main(int argc, char* argv[]);
|
||||||
int interactive_mode(void);
|
int interactive_mode(void);
|
||||||
int command_line_mode(int argc, char* argv[]);
|
int command_line_mode(int argc, char* argv[]);
|
||||||
|
|
||||||
// USB drive detection functions
|
// OTP thumb drive detection function
|
||||||
int scan_usb_drives_for_pads(struct USBPadInfo** usb_pads, int* usb_count);
|
int detect_otp_thumb_drive(char* otp_drive_path, size_t path_size);
|
||||||
int resolve_state_conflicts(const char* chksum, struct USBPadInfo* usb_pads, int usb_count,
|
|
||||||
uint64_t local_offset, uint64_t* resolved_offset, char** authoritative_path);
|
|
||||||
void free_usb_pads(struct USBPadInfo* usb_pads, int count);
|
|
||||||
|
|
||||||
// Editor and file manager functions
|
// Editor and file manager functions
|
||||||
char* get_preferred_editor(void);
|
char* get_preferred_editor(void);
|
||||||
@@ -124,6 +115,15 @@ void get_directory_display(const char* file_path, char* result, size_t result_si
|
|||||||
void print_usage(const char* program_name);
|
void print_usage(const char* program_name);
|
||||||
|
|
||||||
int main(int argc, char* argv[]) {
|
int main(int argc, char* argv[]) {
|
||||||
|
// Check for OTP thumb drive on startup
|
||||||
|
char otp_drive_path[512];
|
||||||
|
if (detect_otp_thumb_drive(otp_drive_path, sizeof(otp_drive_path))) {
|
||||||
|
printf("Detected OTP thumb drive: %s\n", otp_drive_path);
|
||||||
|
printf("Using as default pads directory for this session.\n\n");
|
||||||
|
strncpy(current_pads_dir, otp_drive_path, sizeof(current_pads_dir) - 1);
|
||||||
|
current_pads_dir[sizeof(current_pads_dir) - 1] = '\0';
|
||||||
|
}
|
||||||
|
|
||||||
if (argc == 1) {
|
if (argc == 1) {
|
||||||
return interactive_mode();
|
return interactive_mode();
|
||||||
} else {
|
} else {
|
||||||
@@ -132,12 +132,16 @@ int main(int argc, char* argv[]) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
int interactive_mode(void) {
|
int interactive_mode(void) {
|
||||||
// printf("\n\n\n\n=== OTP Cipher %s ===\n\n", get_version());
|
char input[10];
|
||||||
|
|
||||||
while (1) {
|
while (1) {
|
||||||
show_main_menu();
|
show_main_menu();
|
||||||
char input[10];
|
|
||||||
if (fgets(input, sizeof(input), stdin)) {
|
if (!fgets(input, sizeof(input), stdin)) {
|
||||||
|
printf("Goodbye!\n");
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
|
||||||
char choice = toupper(input[0]);
|
char choice = toupper(input[0]);
|
||||||
|
|
||||||
switch (choice) {
|
switch (choice) {
|
||||||
@@ -154,19 +158,15 @@ int interactive_mode(void) {
|
|||||||
handle_pads_menu();
|
handle_pads_menu();
|
||||||
break;
|
break;
|
||||||
case 'X':
|
case 'X':
|
||||||
case 'Q':
|
|
||||||
printf("Goodbye!\n");
|
printf("Goodbye!\n");
|
||||||
return 0;
|
return 0;
|
||||||
default:
|
default:
|
||||||
printf("Invalid option. Please select T, F, D, P, or X.\n");
|
printf("Invalid choice. Please try again.\n");
|
||||||
continue;
|
break;
|
||||||
}
|
}
|
||||||
} else {
|
|
||||||
printf("Error reading input. Please try again.\n");
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
printf("\n");
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
return 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
int command_line_mode(int argc, char* argv[]) {
|
int command_line_mode(int argc, char* argv[]) {
|
||||||
@@ -647,25 +647,19 @@ uint64_t parse_size_string(const char* size_str) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
char* find_pad_by_prefix(const char* prefix) {
|
char* find_pad_by_prefix(const char* prefix) {
|
||||||
// First scan for USB pads
|
DIR* dir = opendir(current_pads_dir);
|
||||||
struct USBPadInfo* usb_pads = NULL;
|
|
||||||
int usb_count = 0;
|
|
||||||
scan_usb_drives_for_pads(&usb_pads, &usb_count);
|
|
||||||
|
|
||||||
DIR* dir = opendir(PADS_DIR);
|
|
||||||
if (!dir) {
|
if (!dir) {
|
||||||
printf("Error: Cannot open pads directory\n");
|
printf("Error: Cannot open pads directory %s\n", current_pads_dir);
|
||||||
free_usb_pads(usb_pads, usb_count);
|
|
||||||
return NULL;
|
return NULL;
|
||||||
}
|
}
|
||||||
|
|
||||||
struct dirent* entry;
|
struct dirent* entry;
|
||||||
char* matches[200]; // Store up to 200 matches (local + USB)
|
char* matches[100]; // Store up to 100 matches
|
||||||
int match_count = 0;
|
int match_count = 0;
|
||||||
|
|
||||||
// Always try hex prefix matching first on local pads
|
// Always try hex prefix matching first
|
||||||
size_t prefix_len = strlen(prefix);
|
size_t prefix_len = strlen(prefix);
|
||||||
while ((entry = readdir(dir)) != NULL && match_count < 200) {
|
while ((entry = readdir(dir)) != NULL && match_count < 100) {
|
||||||
// Skip . and .. entries, and only process .pad files
|
// Skip . and .. entries, and only process .pad files
|
||||||
if (entry->d_name[0] == '.') continue;
|
if (entry->d_name[0] == '.') continue;
|
||||||
if (!strstr(entry->d_name, ".pad")) continue;
|
if (!strstr(entry->d_name, ".pad")) continue;
|
||||||
@@ -680,35 +674,13 @@ char* find_pad_by_prefix(const char* prefix) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// Also check USB pads for prefix matches
|
|
||||||
for (int i = 0; i < usb_count && match_count < 200; i++) {
|
|
||||||
if (strncmp(usb_pads[i].chksum, prefix, prefix_len) == 0) {
|
|
||||||
// Check if we already have this checksum from local pads
|
|
||||||
int is_duplicate = 0;
|
|
||||||
for (int j = 0; j < match_count; j++) {
|
|
||||||
if (strcmp(matches[j], usb_pads[i].chksum) == 0) {
|
|
||||||
is_duplicate = 1;
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
if (!is_duplicate) {
|
|
||||||
matches[match_count] = malloc(65);
|
|
||||||
strncpy(matches[match_count], usb_pads[i].chksum, 64);
|
|
||||||
matches[match_count][64] = '\0';
|
|
||||||
match_count++;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// If no hex prefix matches and it looks like a small number, try number selection
|
// If no hex prefix matches and it looks like a small number, try number selection
|
||||||
if (match_count == 0) {
|
if (match_count == 0) {
|
||||||
char* endptr;
|
char* endptr;
|
||||||
int selection = strtol(prefix, &endptr, 10);
|
int selection = strtol(prefix, &endptr, 10);
|
||||||
if (*endptr == '\0' && selection > 0 && selection <= 200) {
|
if (*endptr == '\0' && selection > 0 && selection <= 100) {
|
||||||
// It's a number, find the nth pad (counting local + USB)
|
// It's a number, find the nth pad
|
||||||
int current = 0;
|
int current = 0;
|
||||||
|
|
||||||
// Count local pads first
|
|
||||||
rewinddir(dir);
|
rewinddir(dir);
|
||||||
while ((entry = readdir(dir)) != NULL) {
|
while ((entry = readdir(dir)) != NULL) {
|
||||||
if (entry->d_name[0] == '.') continue;
|
if (entry->d_name[0] == '.') continue;
|
||||||
@@ -724,45 +696,10 @@ char* find_pad_by_prefix(const char* prefix) {
|
|||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// If not found in local pads, check USB pads
|
|
||||||
if (match_count == 0) {
|
|
||||||
for (int i = 0; i < usb_count; i++) {
|
|
||||||
// Skip if this USB pad is already counted in local pads
|
|
||||||
int is_local = 0;
|
|
||||||
rewinddir(dir);
|
|
||||||
while ((entry = readdir(dir)) != NULL) {
|
|
||||||
if (entry->d_name[0] == '.') continue;
|
|
||||||
if (!strstr(entry->d_name, ".pad")) continue;
|
|
||||||
if (strlen(entry->d_name) != 68) continue;
|
|
||||||
|
|
||||||
char local_chksum[65];
|
|
||||||
strncpy(local_chksum, entry->d_name, 64);
|
|
||||||
local_chksum[64] = '\0';
|
|
||||||
|
|
||||||
if (strcmp(local_chksum, usb_pads[i].chksum) == 0) {
|
|
||||||
is_local = 1;
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
if (!is_local) {
|
|
||||||
current++;
|
|
||||||
if (current == selection) {
|
|
||||||
matches[match_count] = malloc(65);
|
|
||||||
strncpy(matches[match_count], usb_pads[i].chksum, 64);
|
|
||||||
matches[match_count][64] = '\0';
|
|
||||||
match_count = 1;
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
closedir(dir);
|
closedir(dir);
|
||||||
free_usb_pads(usb_pads, usb_count);
|
|
||||||
|
|
||||||
if (match_count == 0) {
|
if (match_count == 0) {
|
||||||
printf("No pads found matching '%s'\n", prefix);
|
printf("No pads found matching '%s'\n", prefix);
|
||||||
@@ -809,9 +746,9 @@ char* find_pad_by_prefix(const char* prefix) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
int list_available_pads(void) {
|
int list_available_pads(void) {
|
||||||
DIR* dir = opendir(PADS_DIR);
|
DIR* dir = opendir(current_pads_dir);
|
||||||
if (!dir) {
|
if (!dir) {
|
||||||
printf("Error: Cannot open pads directory\n");
|
printf("Error: Cannot open pads directory %s\n", current_pads_dir);
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -830,8 +767,8 @@ int list_available_pads(void) {
|
|||||||
chksum[64] = '\0';
|
chksum[64] = '\0';
|
||||||
|
|
||||||
// Get pad file size
|
// Get pad file size
|
||||||
char full_path[300]; // Increased buffer size to accommodate longer paths
|
char full_path[1024]; // Increased buffer size to accommodate longer paths
|
||||||
snprintf(full_path, sizeof(full_path), "%s/%s", PADS_DIR, entry->d_name);
|
snprintf(full_path, sizeof(full_path), "%s/%s", current_pads_dir, entry->d_name);
|
||||||
struct stat st;
|
struct stat st;
|
||||||
if (stat(full_path, &st) == 0) {
|
if (stat(full_path, &st) == 0) {
|
||||||
// Get used bytes from state
|
// Get used bytes from state
|
||||||
@@ -2158,8 +2095,8 @@ int decrypt_ascii_file(const char* input_file, const char* output_file) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
int read_state_offset(const char* pad_chksum, uint64_t* offset) {
|
int read_state_offset(const char* pad_chksum, uint64_t* offset) {
|
||||||
char state_filename[MAX_HASH_LENGTH + 20];
|
char state_filename[1024];
|
||||||
snprintf(state_filename, sizeof(state_filename), "%s/%s.state", PADS_DIR, pad_chksum);
|
snprintf(state_filename, sizeof(state_filename), "%s/%s.state", current_pads_dir, pad_chksum);
|
||||||
|
|
||||||
FILE* state_file = fopen(state_filename, "rb");
|
FILE* state_file = fopen(state_filename, "rb");
|
||||||
if (!state_file) {
|
if (!state_file) {
|
||||||
@@ -2178,8 +2115,8 @@ int read_state_offset(const char* pad_chksum, uint64_t* offset) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
int write_state_offset(const char* pad_chksum, uint64_t offset) {
|
int write_state_offset(const char* pad_chksum, uint64_t offset) {
|
||||||
char state_filename[MAX_HASH_LENGTH + 20];
|
char state_filename[1024];
|
||||||
snprintf(state_filename, sizeof(state_filename), "%s/%s.state", PADS_DIR, pad_chksum);
|
snprintf(state_filename, sizeof(state_filename), "%s/%s.state", current_pads_dir, pad_chksum);
|
||||||
|
|
||||||
FILE* state_file = fopen(state_filename, "wb");
|
FILE* state_file = fopen(state_filename, "wb");
|
||||||
if (!state_file) {
|
if (!state_file) {
|
||||||
@@ -2320,8 +2257,8 @@ int collect_keyboard_entropy(unsigned char* entropy_buffer, size_t max_size, siz
|
|||||||
// Directory management functions
|
// Directory management functions
|
||||||
int ensure_pads_directory(void) {
|
int ensure_pads_directory(void) {
|
||||||
struct stat st = {0};
|
struct stat st = {0};
|
||||||
if (stat(PADS_DIR, &st) == -1) {
|
if (stat(current_pads_dir, &st) == -1) {
|
||||||
if (mkdir(PADS_DIR, 0755) != 0) {
|
if (mkdir(current_pads_dir, 0755) != 0) {
|
||||||
return 1;
|
return 1;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -2352,196 +2289,101 @@ void get_default_file_path(const char* filename, char* result_path, size_t resul
|
|||||||
}
|
}
|
||||||
|
|
||||||
void get_pad_path(const char* chksum, char* pad_path, char* state_path) {
|
void get_pad_path(const char* chksum, char* pad_path, char* state_path) {
|
||||||
snprintf(pad_path, MAX_HASH_LENGTH + 20, "%s/%s.pad", PADS_DIR, chksum);
|
snprintf(pad_path, 1024, "%s/%s.pad", current_pads_dir, chksum);
|
||||||
snprintf(state_path, MAX_HASH_LENGTH + 20, "%s/%s.state", PADS_DIR, chksum);
|
snprintf(state_path, 1024, "%s/%s.state", current_pads_dir, chksum);
|
||||||
}
|
}
|
||||||
|
|
||||||
// USB drive detection functions implementation
|
// OTP thumb drive detection function implementation
|
||||||
int scan_usb_drives_for_pads(struct USBPadInfo** usb_pads, int* usb_count) {
|
int detect_otp_thumb_drive(char* otp_drive_path, size_t path_size) {
|
||||||
const char* mount_dirs[] = {"/media", "/run/media", "/mnt", NULL};
|
const char* mount_dirs[] = {"/media", "/run/media", "/mnt", NULL};
|
||||||
struct USBPadInfo* pads = malloc(100 * sizeof(struct USBPadInfo)); // Support up to 100 USB pads
|
|
||||||
int count = 0;
|
|
||||||
|
|
||||||
if (!pads) {
|
|
||||||
*usb_pads = NULL;
|
|
||||||
*usb_count = 0;
|
|
||||||
return 1;
|
|
||||||
}
|
|
||||||
|
|
||||||
for (int mount_idx = 0; mount_dirs[mount_idx] != NULL; mount_idx++) {
|
for (int mount_idx = 0; mount_dirs[mount_idx] != NULL; mount_idx++) {
|
||||||
DIR* mount_dir = opendir(mount_dirs[mount_idx]);
|
DIR* mount_dir = opendir(mount_dirs[mount_idx]);
|
||||||
if (!mount_dir) continue;
|
if (!mount_dir) continue;
|
||||||
|
|
||||||
struct dirent* mount_entry;
|
struct dirent* mount_entry;
|
||||||
while ((mount_entry = readdir(mount_dir)) != NULL && count < 100) {
|
while ((mount_entry = readdir(mount_dir)) != NULL) {
|
||||||
if (mount_entry->d_name[0] == '.') continue;
|
if (mount_entry->d_name[0] == '.') continue;
|
||||||
|
|
||||||
char mount_path[1024];
|
char mount_path[512];
|
||||||
snprintf(mount_path, sizeof(mount_path), "%s/%s", mount_dirs[mount_idx], mount_entry->d_name);
|
snprintf(mount_path, sizeof(mount_path), "%s/%s", mount_dirs[mount_idx], mount_entry->d_name);
|
||||||
|
|
||||||
// For /run/media, we need to go one level deeper (skip username)
|
// For /media, we need to go one level deeper (user directories)
|
||||||
if (strcmp(mount_dirs[mount_idx], "/run/media") == 0) {
|
if (strcmp(mount_dirs[mount_idx], "/media") == 0) {
|
||||||
|
// This is /media/[username] - look inside for drives
|
||||||
DIR* user_dir = opendir(mount_path);
|
DIR* user_dir = opendir(mount_path);
|
||||||
if (!user_dir) continue;
|
if (!user_dir) continue;
|
||||||
|
|
||||||
struct dirent* user_entry;
|
struct dirent* user_entry;
|
||||||
while ((user_entry = readdir(user_dir)) != NULL && count < 100) {
|
while ((user_entry = readdir(user_dir)) != NULL) {
|
||||||
if (user_entry->d_name[0] == '.') continue;
|
if (user_entry->d_name[0] == '.') continue;
|
||||||
|
|
||||||
char user_mount_path[1024];
|
// Check if drive name starts with "OTP"
|
||||||
|
if (strncmp(user_entry->d_name, "OTP", 3) != 0) continue;
|
||||||
|
|
||||||
|
char user_mount_path[512];
|
||||||
snprintf(user_mount_path, sizeof(user_mount_path), "%s/%s", mount_path, user_entry->d_name);
|
snprintf(user_mount_path, sizeof(user_mount_path), "%s/%s", mount_path, user_entry->d_name);
|
||||||
|
|
||||||
// Scan this mount point for pads
|
// Check if this is a readable directory
|
||||||
DIR* drive_dir = opendir(user_mount_path);
|
DIR* drive_dir = opendir(user_mount_path);
|
||||||
if (!drive_dir) continue;
|
if (drive_dir) {
|
||||||
|
|
||||||
struct dirent* drive_entry;
|
|
||||||
while ((drive_entry = readdir(drive_dir)) != NULL && count < 100) {
|
|
||||||
// Look for .pad files in root of drive
|
|
||||||
if (strstr(drive_entry->d_name, ".pad") && strlen(drive_entry->d_name) == 68) {
|
|
||||||
char pad_path[2048], state_path[2048];
|
|
||||||
snprintf(pad_path, sizeof(pad_path), "%s/%s", user_mount_path, drive_entry->d_name);
|
|
||||||
|
|
||||||
// Extract checksum from filename
|
|
||||||
strncpy(pads[count].chksum, drive_entry->d_name, 64);
|
|
||||||
pads[count].chksum[64] = '\0';
|
|
||||||
|
|
||||||
// Check if corresponding .state file exists
|
|
||||||
snprintf(state_path, sizeof(state_path), "%s/%s.state", user_mount_path, pads[count].chksum);
|
|
||||||
if (access(state_path, R_OK) == 0) {
|
|
||||||
// Valid pad found
|
|
||||||
strncpy(pads[count].pad_path, pad_path, sizeof(pads[count].pad_path) - 1);
|
|
||||||
strncpy(pads[count].state_path, state_path, sizeof(pads[count].state_path) - 1);
|
|
||||||
strncpy(pads[count].mount_point, user_mount_path, sizeof(pads[count].mount_point) - 1);
|
|
||||||
|
|
||||||
// Read state offset
|
|
||||||
FILE* state_file = fopen(state_path, "rb");
|
|
||||||
if (state_file) {
|
|
||||||
if (fread(&pads[count].state_offset, sizeof(uint64_t), 1, state_file) != 1) {
|
|
||||||
pads[count].state_offset = 0;
|
|
||||||
}
|
|
||||||
fclose(state_file);
|
|
||||||
} else {
|
|
||||||
pads[count].state_offset = 0;
|
|
||||||
}
|
|
||||||
|
|
||||||
count++;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
closedir(drive_dir);
|
closedir(drive_dir);
|
||||||
|
strncpy(otp_drive_path, user_mount_path, path_size - 1);
|
||||||
|
otp_drive_path[path_size - 1] = '\0';
|
||||||
|
closedir(user_dir);
|
||||||
|
closedir(mount_dir);
|
||||||
|
return 1; // Found OTP drive
|
||||||
|
}
|
||||||
|
}
|
||||||
|
closedir(user_dir);
|
||||||
|
} else if (strcmp(mount_dirs[mount_idx], "/run/media") == 0) {
|
||||||
|
// For /run/media, we need to go one level deeper (skip username)
|
||||||
|
DIR* user_dir = opendir(mount_path);
|
||||||
|
if (!user_dir) continue;
|
||||||
|
|
||||||
|
struct dirent* user_entry;
|
||||||
|
while ((user_entry = readdir(user_dir)) != NULL) {
|
||||||
|
if (user_entry->d_name[0] == '.') continue;
|
||||||
|
|
||||||
|
// Check if drive name starts with "OTP"
|
||||||
|
if (strncmp(user_entry->d_name, "OTP", 3) != 0) continue;
|
||||||
|
|
||||||
|
char user_mount_path[512];
|
||||||
|
snprintf(user_mount_path, sizeof(user_mount_path), "%s/%s", mount_path, user_entry->d_name);
|
||||||
|
|
||||||
|
// Check if this is a readable directory
|
||||||
|
DIR* drive_dir = opendir(user_mount_path);
|
||||||
|
if (drive_dir) {
|
||||||
|
closedir(drive_dir);
|
||||||
|
strncpy(otp_drive_path, user_mount_path, path_size - 1);
|
||||||
|
otp_drive_path[path_size - 1] = '\0';
|
||||||
|
closedir(user_dir);
|
||||||
|
closedir(mount_dir);
|
||||||
|
return 1; // Found OTP drive
|
||||||
|
}
|
||||||
}
|
}
|
||||||
closedir(user_dir);
|
closedir(user_dir);
|
||||||
} else {
|
} else {
|
||||||
// Direct mount point (like /media/DRIVE_NAME or /mnt/DRIVE_NAME)
|
// Direct mount point (like /mnt/OTP_DRIVE)
|
||||||
|
// Check if drive name starts with "OTP"
|
||||||
|
if (strncmp(mount_entry->d_name, "OTP", 3) == 0) {
|
||||||
DIR* drive_dir = opendir(mount_path);
|
DIR* drive_dir = opendir(mount_path);
|
||||||
if (!drive_dir) continue;
|
if (drive_dir) {
|
||||||
|
|
||||||
struct dirent* drive_entry;
|
|
||||||
while ((drive_entry = readdir(drive_dir)) != NULL && count < 100) {
|
|
||||||
// Look for .pad files in root of drive
|
|
||||||
if (strstr(drive_entry->d_name, ".pad") && strlen(drive_entry->d_name) == 68) {
|
|
||||||
char pad_path[2048], state_path[2048];
|
|
||||||
snprintf(pad_path, sizeof(pad_path), "%s/%s", mount_path, drive_entry->d_name);
|
|
||||||
|
|
||||||
// Extract checksum from filename
|
|
||||||
strncpy(pads[count].chksum, drive_entry->d_name, 64);
|
|
||||||
pads[count].chksum[64] = '\0';
|
|
||||||
|
|
||||||
// Check if corresponding .state file exists
|
|
||||||
snprintf(state_path, sizeof(state_path), "%s/%s.state", mount_path, pads[count].chksum);
|
|
||||||
if (access(state_path, R_OK) == 0) {
|
|
||||||
// Valid pad found
|
|
||||||
strncpy(pads[count].pad_path, pad_path, sizeof(pads[count].pad_path) - 1);
|
|
||||||
strncpy(pads[count].state_path, state_path, sizeof(pads[count].state_path) - 1);
|
|
||||||
strncpy(pads[count].mount_point, mount_path, sizeof(pads[count].mount_point) - 1);
|
|
||||||
|
|
||||||
// Read state offset
|
|
||||||
FILE* state_file = fopen(state_path, "rb");
|
|
||||||
if (state_file) {
|
|
||||||
if (fread(&pads[count].state_offset, sizeof(uint64_t), 1, state_file) != 1) {
|
|
||||||
pads[count].state_offset = 0;
|
|
||||||
}
|
|
||||||
fclose(state_file);
|
|
||||||
} else {
|
|
||||||
pads[count].state_offset = 0;
|
|
||||||
}
|
|
||||||
|
|
||||||
count++;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
closedir(drive_dir);
|
closedir(drive_dir);
|
||||||
|
strncpy(otp_drive_path, mount_path, path_size - 1);
|
||||||
|
otp_drive_path[path_size - 1] = '\0';
|
||||||
|
closedir(mount_dir);
|
||||||
|
return 1; // Found OTP drive
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
closedir(mount_dir);
|
closedir(mount_dir);
|
||||||
}
|
}
|
||||||
|
|
||||||
*usb_pads = pads;
|
return 0; // No OTP drive found
|
||||||
*usb_count = count;
|
|
||||||
return 0;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
int resolve_state_conflicts(const char* chksum, struct USBPadInfo* usb_pads, int usb_count,
|
|
||||||
uint64_t local_offset, uint64_t* resolved_offset, char** authoritative_path) {
|
|
||||||
uint64_t max_offset = local_offset;
|
|
||||||
int conflicts_found = 0;
|
|
||||||
char local_path[512];
|
|
||||||
snprintf(local_path, sizeof(local_path), "%s/%s.state", PADS_DIR, chksum);
|
|
||||||
|
|
||||||
// Initially assume local is authoritative
|
|
||||||
*authoritative_path = strdup(local_path);
|
|
||||||
|
|
||||||
// Check all USB pads with same checksum
|
|
||||||
for (int i = 0; i < usb_count; i++) {
|
|
||||||
if (strcmp(usb_pads[i].chksum, chksum) == 0) {
|
|
||||||
if (usb_pads[i].state_offset != local_offset) {
|
|
||||||
conflicts_found = 1;
|
|
||||||
if (usb_pads[i].state_offset > max_offset) {
|
|
||||||
max_offset = usb_pads[i].state_offset;
|
|
||||||
free(*authoritative_path);
|
|
||||||
*authoritative_path = strdup(usb_pads[i].state_path);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
if (conflicts_found) {
|
|
||||||
printf("Warning: State conflict detected for pad %s\n", chksum);
|
|
||||||
printf("Multiple state files found with different offsets. Using highest offset: %lu\n", max_offset);
|
|
||||||
|
|
||||||
// Update all state files to use the maximum offset
|
|
||||||
// Update local state file
|
|
||||||
FILE* local_state = fopen(local_path, "wb");
|
|
||||||
if (local_state) {
|
|
||||||
fwrite(&max_offset, sizeof(uint64_t), 1, local_state);
|
|
||||||
fclose(local_state);
|
|
||||||
}
|
|
||||||
|
|
||||||
// Update USB state files
|
|
||||||
for (int i = 0; i < usb_count; i++) {
|
|
||||||
if (strcmp(usb_pads[i].chksum, chksum) == 0) {
|
|
||||||
FILE* usb_state = fopen(usb_pads[i].state_path, "wb");
|
|
||||||
if (usb_state) {
|
|
||||||
fwrite(&max_offset, sizeof(uint64_t), 1, usb_state);
|
|
||||||
fclose(usb_state);
|
|
||||||
}
|
|
||||||
// Update the cached offset
|
|
||||||
usb_pads[i].state_offset = max_offset;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
*resolved_offset = max_offset;
|
|
||||||
return conflicts_found ? 1 : 0;
|
|
||||||
}
|
|
||||||
|
|
||||||
void free_usb_pads(struct USBPadInfo* usb_pads, int count) {
|
|
||||||
(void)count; // Suppress unused parameter warning
|
|
||||||
if (usb_pads) {
|
|
||||||
free(usb_pads);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
@@ -3095,59 +2937,42 @@ int handle_file_encrypt(void) {
|
|||||||
|
|
||||||
int handle_pads_menu(void) {
|
int handle_pads_menu(void) {
|
||||||
printf("\n=== Pad Management ===\n");
|
printf("\n=== Pad Management ===\n");
|
||||||
printf("Scanning for USB drives...\n");
|
|
||||||
|
|
||||||
// Scan for USB pads first
|
// Get list of pads from current directory
|
||||||
struct USBPadInfo* usb_pads = NULL;
|
DIR* dir = opendir(current_pads_dir);
|
||||||
int usb_count = 0;
|
|
||||||
scan_usb_drives_for_pads(&usb_pads, &usb_count);
|
|
||||||
|
|
||||||
// Get list of local pads
|
|
||||||
DIR* dir = opendir(PADS_DIR);
|
|
||||||
if (!dir) {
|
if (!dir) {
|
||||||
printf("Error: Cannot open pads directory\n");
|
printf("Error: Cannot open pads directory %s\n", current_pads_dir);
|
||||||
free_usb_pads(usb_pads, usb_count);
|
|
||||||
return 1;
|
return 1;
|
||||||
}
|
}
|
||||||
|
|
||||||
// Structure to store combined pad information
|
// Structure to store pad information
|
||||||
struct PadInfo {
|
struct PadInfo {
|
||||||
char chksum[65];
|
char chksum[65];
|
||||||
char size_str[32];
|
char size_str[32];
|
||||||
char used_str[32];
|
char used_str[32];
|
||||||
double percentage;
|
double percentage;
|
||||||
char location[256]; // Store location info (local/USB)
|
char location[256]; // Store location info
|
||||||
int is_usb; // Flag to indicate USB pad
|
|
||||||
};
|
};
|
||||||
|
|
||||||
struct PadInfo pads[200]; // Support up to 200 total pads (local + USB)
|
struct PadInfo pads[100]; // Support up to 100 pads
|
||||||
int pad_count = 0;
|
int pad_count = 0;
|
||||||
|
|
||||||
// First, collect all local pad information
|
// Collect all pad information
|
||||||
struct dirent* entry;
|
struct dirent* entry;
|
||||||
while ((entry = readdir(dir)) != NULL && pad_count < 200) {
|
while ((entry = readdir(dir)) != NULL && pad_count < 100) {
|
||||||
if (strstr(entry->d_name, ".pad") && strlen(entry->d_name) == 68) {
|
if (strstr(entry->d_name, ".pad") && strlen(entry->d_name) == 68) {
|
||||||
strncpy(pads[pad_count].chksum, entry->d_name, 64);
|
strncpy(pads[pad_count].chksum, entry->d_name, 64);
|
||||||
pads[pad_count].chksum[64] = '\0';
|
pads[pad_count].chksum[64] = '\0';
|
||||||
|
|
||||||
// Get pad file size and usage info
|
// Get pad file size and usage info
|
||||||
char full_path[300];
|
char full_path[512];
|
||||||
snprintf(full_path, sizeof(full_path), "%s/%s", PADS_DIR, entry->d_name);
|
snprintf(full_path, sizeof(full_path), "%s/%s", current_pads_dir, entry->d_name);
|
||||||
struct stat st;
|
struct stat st;
|
||||||
if (stat(full_path, &st) == 0) {
|
if (stat(full_path, &st) == 0) {
|
||||||
// Get used bytes from state (check for conflicts with USB)
|
// Get used bytes from state
|
||||||
uint64_t used_bytes;
|
uint64_t used_bytes;
|
||||||
read_state_offset(pads[pad_count].chksum, &used_bytes);
|
read_state_offset(pads[pad_count].chksum, &used_bytes);
|
||||||
|
|
||||||
// Check for state conflicts with USB pads
|
|
||||||
uint64_t resolved_offset;
|
|
||||||
char* authoritative_path;
|
|
||||||
if (resolve_state_conflicts(pads[pad_count].chksum, usb_pads, usb_count,
|
|
||||||
used_bytes, &resolved_offset, &authoritative_path) == 1) {
|
|
||||||
used_bytes = resolved_offset;
|
|
||||||
}
|
|
||||||
free(authoritative_path);
|
|
||||||
|
|
||||||
// Format total size
|
// Format total size
|
||||||
if (st.st_size < 1024) {
|
if (st.st_size < 1024) {
|
||||||
snprintf(pads[pad_count].size_str, sizeof(pads[pad_count].size_str), "%luB", st.st_size);
|
snprintf(pads[pad_count].size_str, sizeof(pads[pad_count].size_str), "%luB", st.st_size);
|
||||||
@@ -3173,9 +2998,8 @@ int handle_pads_menu(void) {
|
|||||||
// Calculate percentage
|
// Calculate percentage
|
||||||
pads[pad_count].percentage = (double)used_bytes / st.st_size * 100.0;
|
pads[pad_count].percentage = (double)used_bytes / st.st_size * 100.0;
|
||||||
|
|
||||||
// Set location info
|
// Set location info using directory display
|
||||||
strcpy(pads[pad_count].location, "pads");
|
get_directory_display(full_path, pads[pad_count].location, sizeof(pads[pad_count].location));
|
||||||
pads[pad_count].is_usb = 0;
|
|
||||||
|
|
||||||
pad_count++;
|
pad_count++;
|
||||||
}
|
}
|
||||||
@@ -3183,59 +3007,6 @@ int handle_pads_menu(void) {
|
|||||||
}
|
}
|
||||||
closedir(dir);
|
closedir(dir);
|
||||||
|
|
||||||
// Then, add USB pads (avoiding duplicates)
|
|
||||||
for (int i = 0; i < usb_count && pad_count < 200; i++) {
|
|
||||||
// Check if this USB pad is already in local pads
|
|
||||||
int is_duplicate = 0;
|
|
||||||
for (int j = 0; j < pad_count; j++) {
|
|
||||||
if (strcmp(pads[j].chksum, usb_pads[i].chksum) == 0) {
|
|
||||||
is_duplicate = 1;
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
if (!is_duplicate) {
|
|
||||||
// Add USB pad
|
|
||||||
strcpy(pads[pad_count].chksum, usb_pads[i].chksum);
|
|
||||||
|
|
||||||
// Get pad file size
|
|
||||||
struct stat st;
|
|
||||||
if (stat(usb_pads[i].pad_path, &st) == 0) {
|
|
||||||
// Format total size
|
|
||||||
if (st.st_size < 1024) {
|
|
||||||
snprintf(pads[pad_count].size_str, sizeof(pads[pad_count].size_str), "%luB", st.st_size);
|
|
||||||
} else if (st.st_size < 1024 * 1024) {
|
|
||||||
snprintf(pads[pad_count].size_str, sizeof(pads[pad_count].size_str), "%.1fKB", (double)st.st_size / 1024.0);
|
|
||||||
} else if (st.st_size < 1024 * 1024 * 1024) {
|
|
||||||
snprintf(pads[pad_count].size_str, sizeof(pads[pad_count].size_str), "%.1fMB", (double)st.st_size / (1024.0 * 1024.0));
|
|
||||||
} else {
|
|
||||||
snprintf(pads[pad_count].size_str, sizeof(pads[pad_count].size_str), "%.2fGB", (double)st.st_size / (1024.0 * 1024.0 * 1024.0));
|
|
||||||
}
|
|
||||||
|
|
||||||
// Format used size (already resolved)
|
|
||||||
uint64_t used_bytes = usb_pads[i].state_offset;
|
|
||||||
if (used_bytes < 1024) {
|
|
||||||
snprintf(pads[pad_count].used_str, sizeof(pads[pad_count].used_str), "%luB", used_bytes);
|
|
||||||
} else if (used_bytes < 1024 * 1024) {
|
|
||||||
snprintf(pads[pad_count].used_str, sizeof(pads[pad_count].used_str), "%.1fKB", (double)used_bytes / 1024.0);
|
|
||||||
} else if (used_bytes < 1024 * 1024 * 1024) {
|
|
||||||
snprintf(pads[pad_count].used_str, sizeof(pads[pad_count].used_str), "%.1fMB", (double)used_bytes / (1024.0 * 1024.0));
|
|
||||||
} else {
|
|
||||||
snprintf(pads[pad_count].used_str, sizeof(pads[pad_count].used_str), "%.2fGB", (double)used_bytes / (1024.0 * 1024.0 * 1024.0));
|
|
||||||
}
|
|
||||||
|
|
||||||
// Calculate percentage
|
|
||||||
pads[pad_count].percentage = (double)used_bytes / st.st_size * 100.0;
|
|
||||||
|
|
||||||
// Set USB location info
|
|
||||||
get_directory_display(usb_pads[i].pad_path, pads[pad_count].location, sizeof(pads[pad_count].location));
|
|
||||||
pads[pad_count].is_usb = 1;
|
|
||||||
|
|
||||||
pad_count++;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
if (pad_count == 0) {
|
if (pad_count == 0) {
|
||||||
printf("No pads found.\n");
|
printf("No pads found.\n");
|
||||||
printf("\nOptions:\n");
|
printf("\nOptions:\n");
|
||||||
@@ -3455,7 +3226,7 @@ void get_directory_display(const char* file_path, char* result, size_t result_si
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Current working directory
|
// Current working directory
|
||||||
if (strcmp(dir_path, ".") == 0 || strcmp(dir_path, PADS_DIR) == 0) {
|
if (strcmp(dir_path, ".") == 0 || strcmp(dir_path, current_pads_dir) == 0) {
|
||||||
strncpy(result, "pads", result_size - 1);
|
strncpy(result, "pads", result_size - 1);
|
||||||
result[result_size - 1] = '\0';
|
result[result_size - 1] = '\0';
|
||||||
return;
|
return;
|
||||||
|
|||||||
Reference in New Issue
Block a user