20#include <config_folders.h>
21#include <config_features.h>
29#include <rtl/digest.h>
30#include <rtl/random.h>
31#include <rtl/bootstrap.hxx>
32#include <rtl/ustrbuf.hxx>
35#include <osl/file.hxx>
36#include <osl/pipe.hxx>
37#include <osl/security.hxx>
38#include <osl/thread.hxx>
39#include <com/sun/star/ucb/CommandAbortedException.hpp>
40#include <com/sun/star/task/XInteractionHandler.hpp>
41#include <com/sun/star/bridge/BridgeFactory.hpp>
42#include <com/sun/star/bridge/UnoUrlResolver.hpp>
43#include <com/sun/star/bridge/XUnoUrlResolver.hpp>
44#include <com/sun/star/deployment/ExtensionManager.hpp>
45#include <com/sun/star/lang/DisposedException.hpp>
46#include <com/sun/star/task/OfficeRestartManager.hpp>
65std::shared_ptr<rtl::Bootstrap> & UnoRc()
67 static std::shared_ptr<rtl::Bootstrap> theRc = []()
69 OUString unorc(
"$BRAND_BASE_DIR/" LIBO_ETC_FOLDER
"/" SAL_CONFIGFILE(
"louno") );
70 ::rtl::Bootstrap::expandMacros( unorc );
71 auto ret = std::make_shared<::rtl::Bootstrap>( unorc );
72 OSL_ASSERT( ret->getHandle() !=
nullptr );
78OUString generateOfficePipeId()
86 throw Exception(
"Extension Manager: Could not obtain path for UserInstallation.",
nullptr);
89 rtlDigest digest = rtl_digest_create( rtl_Digest_AlgorithmMD5 );
91 throw RuntimeException(
"cannot get digest rtl_Digest_AlgorithmMD5!",
nullptr );
95 reinterpret_cast<sal_uInt8 const *
>(userPath.getStr());
97 sal_uInt32 md5_key_len = rtl_digest_queryLength( digest );
98 std::unique_ptr<sal_uInt8[]> md5_buf(
new sal_uInt8 [ md5_key_len ] );
100 rtl_digest_init( digest, data,
static_cast<sal_uInt32
>(size) );
101 rtl_digest_update( digest, data,
static_cast<sal_uInt32
>(size) );
102 rtl_digest_get( digest, md5_buf.get(), md5_key_len );
103 rtl_digest_destroy( digest );
108 buf.append(
"SingleOfficeIPC_" );
109 for ( sal_uInt32 i = 0;
i < md5_key_len; ++
i ) {
110 buf.append(
static_cast<sal_Int32
>(md5_buf[ i ]), 0x10 );
112 return buf.makeStringAndClear();
115bool existsOfficePipe()
117 static OUString OfficePipeId = generateOfficePipeId();
119 OUString
const & pipeId = OfficePipeId;
120 if (pipeId.isEmpty())
123 ::osl::Pipe pipe( pipeId, osl_Pipe_OPEN, sec );
128bool getModifyTimeTargetFile(
const OUString &rFileURL, TimeValue &rTime)
132 if (aResolver.fetchFileStatus(rFileURL) != osl::FileBase::E_None)
135 rTime = aResolver.m_aStatus.getModifyTime();
143bool compareExtensionFolderWithLastSynchronizedFile(
144 OUString
const & folderURL, OUString
const & fileURL)
146 bool bNeedsSync =
false;
147 ::osl::DirectoryItem itemExtFolder;
148 ::osl::File::RC err1 =
149 ::osl::DirectoryItem::get(folderURL, itemExtFolder);
151 if (err1 == ::osl::File::E_NOENT)
155 else if (err1 != ::osl::File::E_None)
157 OSL_FAIL(
"Cannot access extension folder");
162 ::osl::DirectoryItem itemFile;
163 ::osl::File::RC err2 = ::osl::DirectoryItem::get(fileURL, itemFile);
164 if (err2 == ::osl::File::E_NOENT)
169 else if (err2 != ::osl::File::E_None)
171 OSL_FAIL(
"Cannot access file lastsynchronized");
177 TimeValue timeFolder;
178 if (getModifyTimeTargetFile(folderURL, timeFolder))
181 if (getModifyTimeTargetFile(fileURL, timeFile))
183 if (timeFile.Seconds < timeFolder.Seconds)
201bool needToSyncRepository(std::u16string_view name)
205 if ( name == u
"bundled" )
207 folder =
"$BUNDLED_EXTENSIONS";
208 file =
"$BUNDLED_EXTENSIONS_USER/lastsynchronized";
210 else if ( name == u
"shared" )
212 folder =
"$UNO_SHARED_PACKAGES_CACHE/uno_packages";
213 file =
"$SHARED_EXTENSIONS_USER/lastsynchronized";
220 ::rtl::Bootstrap::expandMacros(folder);
221 ::rtl::Bootstrap::expandMacros(file);
222 return compareExtensionFolderWithLastSynchronizedFile(
231OUString encodeForRcFile( std::u16string_view str )
234 OUStringBuffer buf(64);
236 const size_t len = str.size();
237 for ( ;
pos < len; ++
pos ) {
249 return buf.makeStringAndClear();
254OUString
makeURL( std::u16string_view baseURL, OUString
const & relPath_ )
256 OUStringBuffer buf(128);
257 if (baseURL.size() > 1 && baseURL[ baseURL.size() - 1 ] ==
'/')
258 buf.append( baseURL.substr(0, baseURL.size() - 1) );
260 buf.append( baseURL );
261 OUString relPath(relPath_);
262 if( relPath.startsWith(
"/") )
263 relPath = relPath.copy( 1 );
264 if (!relPath.isEmpty())
270 relPath = encodeForRcFile(relPath);
275 relPath = ::rtl::Uri::encode( relPath, rtl_UriCharClassUric,
276 rtl_UriEncodeIgnoreEscapes,
277 RTL_TEXTENCODING_UTF8 );
279 buf.append( relPath );
281 return buf.makeStringAndClear();
286 OSL_ASSERT(segment.indexOf(
u'/') == -1);
289 segment, rtl_UriCharClassPchar, rtl_UriEncodeIgnoreEscapes,
290 RTL_TEXTENCODING_UTF8);
291 return makeURL(baseURL, segment);
297 OUString term(term_);
298 UnoRc()->expandMacrosFrom( term );
304 OSL_ASSERT( url.match(
"vnd.sun.star.expand:" ));
305 if (OUString rcterm; url.startsWithIgnoreAsciiCase(
"vnd.sun.star.expand:", &rcterm)) {
307 rcterm = ::rtl::Uri::decode(
308 rcterm, rtl_UriDecodeWithCharset, RTL_TEXTENCODING_UTF8 );
318 if (OUString rcurl; url.startsWithIgnoreAsciiCase(
"vnd.sun.star.expand:", &rcurl)) {
320 rcurl = ::rtl::Uri::decode(
321 rcurl, rtl_UriDecodeWithCharset, RTL_TEXTENCODING_UTF8 );
323 UnoRc()->expandMacrosFrom( rcurl );
337 oslProcessError
err = osl_getExecutableFile(& sFile.pData);
339 if (osl_Process_E_None ==
err)
341 sFile = sFile.copy(sFile.lastIndexOf(
'/') + 1);
347 sFile ==
"soffice.bin" || sFile ==
"soffice.exe" || sFile ==
"soffice.com"
348 || sFile ==
"soffice" || sFile ==
"swriter.exe" || sFile ==
"swriter"
349 || sFile ==
"scalc.exe" || sFile ==
"scalc" || sFile ==
"simpress.exe"
350 || sFile ==
"simpress" || sFile ==
"sdraw.exe" || sFile ==
"sdraw"
351 || sFile ==
"sbase.exe" || sFile ==
"sbase"
355 sFile ==
"soffice.bin"
357#error
"Unsupported platform"
363 ret = existsOfficePipe();
367 OSL_FAIL(
"NOT osl_Process_E_None ");
369 ret = existsOfficePipe();
376 OUString
const & appURL, Sequence<OUString>
const & args )
379 oslProcess hProcess =
nullptr;
380 oslProcessError rc = osl_executeProcess(
382 reinterpret_cast<rtl_uString **
>(
383 const_cast<OUString *
>(
args.getConstArray()) ),
385 osl_Process_DETACHED,
392 case osl_Process_E_None:
394 case osl_Process_E_NotFound:
396 case osl_Process_E_TimedOut:
398 case osl_Process_E_NoPermission:
400 case osl_Process_E_Unknown:
402 case osl_Process_E_InvalidError:
415 if (s_hPool ==
nullptr)
418 if (rtl_random_getBytes(
419 s_hPool,
bytes, std::size(
bytes) ) != rtl_Random_E_None) {
423 for (
unsigned char byte :
bytes) {
424 buf.append(
static_cast<sal_Int32
>(
byte), 0x10 );
426 return buf.makeStringAndClear();
431 OUString
const & connectString,
432 Reference<XComponentContext>
const & xLocalContext,
433 AbortChannel
const * abortChannel )
435 Reference<bridge::XUnoUrlResolver> xUnoUrlResolver(
438 for (
int i = 0;
i <= 40; ++
i)
440 if (abortChannel !=
nullptr && abortChannel->isAborted()) {
441 throw ucb::CommandAbortedException(
"abort!" );
444 return xUnoUrlResolver->resolve( connectString );
446 catch (
const connection::NoConnectException &) {
449 std::this_thread::sleep_for( std::chrono::milliseconds(500) );
460 fprintf(
stream,
"%s", s.getStr());
477 memset(buf, 0, 1024);
479 if (fgets(buf, 1024, stdin) !=
nullptr)
481 OUString
value = OStringToOUString(std::string_view(buf), osl_getThreadTextEncoding());
484 throw css::uno::RuntimeException(
"reading from stdin failed");
489 SAL_INFO(
"desktop.deployment", sText);
493 bool force, Reference<ucb::XCommandEnvironment>
const & xCmdEnv)
496 ::rtl::Bootstrap::get(
"DISABLE_EXTENSION_SYNCHRONIZATION", sDisable, OUString() );
497 if (!sDisable.isEmpty())
500 Reference<deployment::XExtensionManager> xExtensionManager;
503 bool bModified =
false;
504 if (force || needToSyncRepository(
u"shared") || needToSyncRepository(
u"bundled"))
507 deployment::ExtensionManager::get(
510 if (xExtensionManager.is())
512 bModified = xExtensionManager->synchronize(
513 Reference<task::XAbortChannel>(), xCmdEnv);
516#if HAVE_FEATURE_MACOSX_SANDBOX
524 restarter->requestRestart(xCmdEnv.is() ? xCmdEnv->getInteractionHandler() :
525 Reference<task::XInteractionHandler>());
538 const Sequence< Reference<css::bridge::XBridge> >seqBridges = bridgeFac->getExistingBridges();
539 for (
const Reference<css::bridge::XBridge>& bridge : seqBridges)
541 Reference<css::lang::XComponent>
comp(bridge, UNO_QUERY);
547 catch (
const css::lang::DisposedException& )
static PathStatus locateUserInstallation(OUString &_rURL)
#define SAL_CONFIGFILE(name)
Reference< XOutputStream > stream
OUString DpResId(TranslateId aId)
#define SAL_INFO(area, stream)
std::locale Create(std::string_view aPrefixName, const LanguageTag &rLocale)
OUString get(TranslateId sContextAndId, const std::locale &loc)
Reference< XComponentContext > getProcessComponentContext()
OUString makeURL(std::u16string_view baseURL, OUString const &relPath_)
appends a relative path to a url.
void syncRepositories(bool force, Reference< ucb::XCommandEnvironment > const &xCmdEnv)
OUString makeRcTerm(OUString const &url)
OUString expandUnoRcUrl(OUString const &url)
OUString readConsole()
reads from the console.
void writeConsoleError(std::u16string_view sText)
writes the argument to the console using the error stream.
void TRACE(OUString const &sText)
print the text to the console in a debug build.
Reference< XInterface > resolveUnoURL(OUString const &connectString, Reference< XComponentContext > const &xLocalContext, AbortChannel const *abortChannel)
static void writeConsoleWithStream(std::u16string_view sText, FILE *stream)
OUString generateRandomPipeId()
OUString expandUnoRcTerm(OUString const &term_)
void writeConsole(std::u16string_view sText)
writes the argument string to the console.
oslProcess raiseProcess(OUString const &appURL, Sequence< OUString > const &args)
void disposeBridges(Reference< css::uno::XComponentContext > const &ctx)
OUString makeURLAppendSysPathSegment(std::u16string_view baseURL, OUString const &segment)
appends a relative path to a url.
css::uno::Reference< css::deployment::XPackageRegistry > create(css::uno::Reference< css::deployment::XPackageRegistry > const &xRootRegistry, OUString const &context, OUString const &cachePath, css::uno::Reference< css::uno::XComponentContext > const &xComponentContext)
constexpr bool starts_with(std::basic_string_view< charT, traits > sv, std::basic_string_view< charT, traits > x) noexcept
OString OUStringToOString(std::u16string_view str, ConnectionSettings const *settings)
std::vector< sal_uInt8 > bytes