Page MenuHomePhabricator
Differential D13651

[identity] Pass Blob client to AuthenticatedService
ClosedPublic
Actions

Authored by bartek on Oct 9 2024, 1:36 AM.
Tags
None
Referenced Files
Unknown Object (File)
Sat, Mar 15, 3:18 AM
Unknown Object (File)
Fri, Mar 14, 5:52 AM
Unknown Object (File)
Fri, Mar 14, 5:10 AM
Unknown Object (File)
Fri, Mar 14, 4:06 AM
Unknown Object (File)
Fri, Mar 14, 3:11 AM
Unknown Object (File)
Wed, Mar 12, 7:58 PM
Unknown Object (File)
Wed, Mar 12, 4:12 PM
Unknown Object (File)
Wed, Mar 12, 11:46 AM
View All Files
Subscribers
ashoat
tomek

Details

Reviewers
varun
will
kamil
Commits
rCOMMbc71ac4c9c70: [identity] Pass Blob client to AuthenticatedService
Summary

Added a BlobServiceClient member to the AuthenticatedService gRPC service. It's going to be needed to remove holders in the next diff

Depends on D13650

Test Plan

cargo build -p identity

Diff Detail

Repository
rCOMM Comm
Lint
Lint Not Applicable
Unit
Tests Not Applicable

Revision Contents
Changeset List

PathSize
services/
identity/
src/
16 lines
grpc_services/
2 lines
41 lines

Diff 45166

View Options

services/identity/src/database.rs

Show All 21 Linesimport type {
MakeDirectoryMediaMissionStep, MakeDirectoryMediaMissionStep,
AndroidScanFileMediaMissionStep, AndroidScanFileMediaMissionStep,
FetchFileHashMediaMissionStep, FetchFileHashMediaMissionStep,
CopyFileMediaMissionStep, CopyFileMediaMissionStep,
} from 'lib/types/media-types.js'; } from 'lib/types/media-types.js';
import { getMessageForException } from 'lib/utils/errors.js'; import { getMessageForException } from 'lib/utils/errors.js';
import { stringToIntArray } from './blob-utils.js'; import { stringToIntArray } from './blob-utils.js';
import { ffmpeg } from './ffmpeg.js'; import { mediaProcessingQueue } from './media-processing-queue.js';
const defaultInputs = Object.freeze({}); const defaultInputs = Object.freeze({});
const defaultFields = Object.freeze({}); const defaultFields = Object.freeze({});
export type FetchFileInfoResult = { export type FetchFileInfoResult = {
+success: true, +success: true,
+uri: string, +uri: string,
+orientation: ?number, +orientation: ?number,
▲ Show 20 Lines • Show All 265 Lines • ▼ Show 20 Lines if (!mediaConfig[mime] || mediaConfig[mime].mediaType !== 'photo_or_video') {
return { steps: [], result: baseMediaType }; return { steps: [], result: baseMediaType };
} }
let hasMultipleFrames, let hasMultipleFrames,
success = false, success = false,
exceptionMessage; exceptionMessage;
const start = Date.now(); const start = Date.now();
try { try {
hasMultipleFrames = await ffmpeg.hasMultipleFrames(path); hasMultipleFrames = await mediaProcessingQueue.hasMultipleFrames(path);
success = true; success = true;
} catch (e) { } catch (e) {
exceptionMessage = getMessageForException(e); exceptionMessage = getMessageForException(e);
} }
const steps = [ const steps = [
{ {
step: 'frame_count', step: 'frame_count',
success, success,
▲ Show 20 Lines • Show All 131 Lines • Show Last 20 Lines
View Options

services/identity/src/grpc_services/authenticated.rs

Show All 21 Linesimport type {
MakeDirectoryMediaMissionStep, MakeDirectoryMediaMissionStep,
AndroidScanFileMediaMissionStep, AndroidScanFileMediaMissionStep,
FetchFileHashMediaMissionStep, FetchFileHashMediaMissionStep,
CopyFileMediaMissionStep, CopyFileMediaMissionStep,
} from 'lib/types/media-types.js'; } from 'lib/types/media-types.js';
import { getMessageForException } from 'lib/utils/errors.js'; import { getMessageForException } from 'lib/utils/errors.js';
import { stringToIntArray } from './blob-utils.js'; import { stringToIntArray } from './blob-utils.js';
import { ffmpeg } from './ffmpeg.js'; import { mediaProcessingQueue } from './media-processing-queue.js';
const defaultInputs = Object.freeze({}); const defaultInputs = Object.freeze({});
const defaultFields = Object.freeze({}); const defaultFields = Object.freeze({});
export type FetchFileInfoResult = { export type FetchFileInfoResult = {
+success: true, +success: true,
+uri: string, +uri: string,
+orientation: ?number, +orientation: ?number,
▲ Show 20 Lines • Show All 265 Lines • ▼ Show 20 Lines if (!mediaConfig[mime] || mediaConfig[mime].mediaType !== 'photo_or_video') {
return { steps: [], result: baseMediaType }; return { steps: [], result: baseMediaType };
} }
let hasMultipleFrames, let hasMultipleFrames,
success = false, success = false,
exceptionMessage; exceptionMessage;
const start = Date.now(); const start = Date.now();
try { try {
hasMultipleFrames = await ffmpeg.hasMultipleFrames(path); hasMultipleFrames = await mediaProcessingQueue.hasMultipleFrames(path);
success = true; success = true;
} catch (e) { } catch (e) {
exceptionMessage = getMessageForException(e); exceptionMessage = getMessageForException(e);
} }
const steps = [ const steps = [
{ {
step: 'frame_count', step: 'frame_count',
success, success,
▲ Show 20 Lines • Show All 131 Lines • Show Last 20 Lines
View Options

services/identity/src/main.rs

Show All 21 Linesimport type {
MakeDirectoryMediaMissionStep, MakeDirectoryMediaMissionStep,
AndroidScanFileMediaMissionStep, AndroidScanFileMediaMissionStep,
FetchFileHashMediaMissionStep, FetchFileHashMediaMissionStep,
CopyFileMediaMissionStep, CopyFileMediaMissionStep,
} from 'lib/types/media-types.js'; } from 'lib/types/media-types.js';
import { getMessageForException } from 'lib/utils/errors.js'; import { getMessageForException } from 'lib/utils/errors.js';
import { stringToIntArray } from './blob-utils.js'; import { stringToIntArray } from './blob-utils.js';
import { ffmpeg } from './ffmpeg.js'; import { mediaProcessingQueue } from './media-processing-queue.js';
const defaultInputs = Object.freeze({}); const defaultInputs = Object.freeze({});
const defaultFields = Object.freeze({}); const defaultFields = Object.freeze({});
export type FetchFileInfoResult = { export type FetchFileInfoResult = {
+success: true, +success: true,
+uri: string, +uri: string,
+orientation: ?number, +orientation: ?number,
▲ Show 20 Lines • Show All 265 Lines • ▼ Show 20 Lines if (!mediaConfig[mime] || mediaConfig[mime].mediaType !== 'photo_or_video') {
return { steps: [], result: baseMediaType }; return { steps: [], result: baseMediaType };
} }
let hasMultipleFrames, let hasMultipleFrames,
success = false, success = false,
exceptionMessage; exceptionMessage;
const start = Date.now(); const start = Date.now();
try { try {
hasMultipleFrames = await ffmpeg.hasMultipleFrames(path); hasMultipleFrames = await mediaProcessingQueue.hasMultipleFrames(path);
success = true; success = true;
} catch (e) { } catch (e) {
exceptionMessage = getMessageForException(e); exceptionMessage = getMessageForException(e);
} }
const steps = [ const steps = [
{ {
step: 'frame_count', step: 'frame_count',
success, success,
▲ Show 20 Lines • Show All 131 Lines • Show Last 20 Lines